airflow.providers.microsoft.azure.triggers.msgraph

模块内容

类

ResponseSerializer

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

MSGraphTrigger

一个 Microsoft Graph API 触发器，允许您对 Microsoft Graph API 执行异步 REST 调用。
class airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer(encoding=None)[源代码]

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

serialize(response)[源代码]
deserialize(response)[源代码]
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, api_version=None, serializer=ResponseSerializer)[源代码]

基类：airflow.triggers.base.BaseTrigger

一个 Microsoft Graph API 触发器，允许您对 Microsoft Graph API 执行异步 REST 调用。

参数

  • url (str) – 在 Microsoft Graph API 上执行的 URL（可使用模板）。

  • response_type (kiota_http.httpx_request_adapter.ResponseType | None) – 响应的预期返回类型，为字符串。 可能的值包括：bytes、str、int、float、bool 和 datetime（默认为 None）。

  • method (str) – 用于执行 REST 调用的 HTTP 方法（默认为 GET）。

  • conn_id (str) – 用于运行操作符的 HTTP 连接 ID（可使用模板）。

  • timeout (float | None) – KiotaRequestAdapter 使用的 HTTP 超时时间（默认为 None）。如果未指定超时或设置为 None，则每次请求都没有 HTTP 超时时间。

  • proxies (dict | None) – 定义要使用的 HTTP 代理的字典（默认为 None）。

  • api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 的 API 版本（默认为 v1）。您可以传递一个名为 APIVersion 的枚举，它有两个可能的成员 v1 和 beta，也可以传递一个字符串，如 v1.0 或 beta。

  • serializer (type[ResponseSerializer]) – 处理响应序列化的类（默认为 ResponseSerializer）。字节将进行 base64 编码为字符串，以便可以将其存储为 XCom。

property conn_id: str[源代码]
property timeout: float | None[源代码]
property proxies: dict | None[源代码]
property api_version: msgraph_core.APIVersion | str[源代码]
template_fields: collections.abc.Sequence[str] = ('url', 'response_type', 'path_parameters', 'url_template', 'query_parameters', 'headers',...[源代码]
classmethod resolve_type(value, default)[源代码]
serialize()[源代码]

序列化 HttpTrigger 参数和类路径。

get_conn()[源代码]
async run()[源代码]

通过 KiotaRequestAdapterHook 发起一系列异步 HTTP 调用。

此条目是否对您有帮助？