airflow.providers.microsoft.azure.triggers.msgraph¶

类¶

`ResponseSerializer`	ResponseSerializer 将响应序列化为字符串。
`MSGraphTrigger`	一个 Microsoft Graph API trigger，允许你对 Microsoft Graph API 执行异步 REST 调用。

模块内容¶

class airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer(encoding=None)[source]¶

ResponseSerializer 将响应序列化为字符串。

encoding[source]¶

serialize(response)[source]¶

deserialize(response)[source]¶

class airflow.providers.microsoft.azure.triggers.msgraph.MSGraphTrigger(url, response_type=None, path_parameters=None, url_template=None, method='GET', query_parameters=None, headers=None, data=None, conn_id=KiotaRequestAdapterHook.default_conn_name, timeout=None, proxies=None, scopes=None, api_version=None, serializer=ResponseSerializer)[source]¶

基类: airflow.triggers.base.BaseTrigger

一个 Microsoft Graph API trigger，允许你对 Microsoft Graph API 执行异步 REST 调用。

参数:

url (str) – 在 Microsoft Graph API 上执行的 url（模板化）。
response_type (str | None) – 响应的预期返回类型字符串。可能的值为: bytes, str, int, float, bool 和 datetime（默认为 None）。
method (str) – 用于执行 REST 调用的 HTTP 方法（默认为 GET）。
conn_id (str) – 用于运行 operator 的 HTTP 连接 ID（模板化）。
timeout (float | None) – KiotaRequestAdapter 使用的 HTTP 超时（默认为 None）。未指定超时或设置为 None 时，每个请求都没有 HTTP 超时。
proxies (dict | None) – 定义要使用的 HTTP 代理的字典（默认为 None）。
scopes (str | list[str] | None) – 要使用的 scopes（默认为 ["https://graph.microsoft.com/.default"]）。
api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 的 API 版本（默认为 v1）。你可以传递一个名为 APIVersion 的枚举，它有两个可能的成员 v1 和 beta，或者你可以传递一个字符串，如 v1.0 或 beta。
serializer (type[ResponseSerializer]) – 处理响应序列化的类（默认为 ResponseSerializer）。Bytes 将被 base64 编码为字符串，以便可以作为 XCom 存储。

template_fields: collections.abc.Sequence[str] = ('url', 'response_type', 'path_parameters', 'url_template', 'query_parameters', 'headers',...[source]¶