airflow.providers.microsoft.azure.operators.msgraph

MSGraphAsyncOperator

一个 Microsoft Graph API operator,允许您执行到 Microsoft Graph API 的 REST 调用。

函数

default_event_handler([事件])

execute_callable(func, value, context, 消息)

模块内容

airflow.providers.microsoft.azure.operators.msgraph.default_event_handler(event=None, **context)[源代码]
airflow.providers.microsoft.azure.operators.msgraph.execute_callable(func, value, context, message)[源代码]
class airflow.providers.microsoft.azure.operators.msgraph.MSGraphAsyncOperator(*, 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, key=XCOM_RETURN_KEY, timeout=None, proxies=None, scopes=None, api_version=None, pagination_function=None, result_processor=lambda result, **context: ..., event_handler=None, serializer=ResponseSerializer, **kwargs)[源代码]

基类: airflow.models.BaseOperator

一个 Microsoft Graph API operator,允许您执行到 Microsoft Graph API 的 REST 调用。

https://learn.microsoft.com/en-us/graph/use-the-api

另请参阅

有关如何使用此 operator 的更多信息,请参阅指南:MSGraphAsyncOperator

参数:
  • url (str) – 在 Microsoft Graph API 上执行的 url(使用模板)。

  • response_type (str | None) – 预期的响应返回类型字符串。可能的值包括:bytes, str, int, float, booldatetime(默认为 None)。

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

  • conn_id (str) – 用于运行此 operator 的 HTTP 连接 ID(使用模板)。

  • key (str) – 用于存储 XCom’s 的键(默认为 “return_value”)。

  • 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.0beta

  • result_processor (Callable[[Any, airflow.utils.context.Context], Any]) – 用于进一步处理 MS Graph API 响应的函数(默认为 lambda: response, context: response)。当 KiotaRequestAdapterHook 返回的响应是 bytes 时,它们将被 base64 编码为字符串。

  • event_handler (Callable[[dict[Any, Any] | None, airflow.utils.context.Context], Any] | None) – 用于处理从 MSGraphTrigger 返回的事件的函数。默认情况下,当 MSGraphTrigger 返回的事件状态为 failed 时,会抛出包含事件消息的 AirflowException,否则返回事件 payload 中的响应。

  • serializer (type[airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer]) – 处理响应序列化的类(默认为 ResponseSerializer)。Bytes 将被 base64 编码为字符串,以便可以存储为 XCom。

template_fields: collections.abc.Sequence[str] = ('url', 'response_type', 'path_parameters', 'url_template', 'query_parameters', 'headers',...[源代码]
url[源代码]
response_type = None[源代码]
path_parameters = None[源代码]
url_template = None[源代码]
method = 'GET'[源代码]
query_parameters = None[源代码]
headers = None[源代码]
data = None[源代码]
conn_id = 'msgraph_default'[源代码]
key = 'return_value'[源代码]
timeout = None[源代码]
proxies = None[源代码]
scopes = None[源代码]
api_version = None[源代码]
pagination_function[源代码]
result_processor[源代码]
event_handler[源代码]
serializer: airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer[源代码]
execute(context)[源代码]

创建 operator 时继承此类。

Context 与渲染 jinja 模板时使用的字典相同。

有关更多 context,请参阅 get_template_context。

execute_complete(context, event=None)[源代码]

当 MSGraphTrigger 完成执行时执行回调。

当 MSGraphTrigger 完成执行时,此方法会自动执行。

classmethod append_result(results, result, append_result_as_list_if_absent=False)[源代码]
pull_xcom(context)[源代码]
push_xcom(context, value)[源代码]
static paginate(operator, response, **context)[源代码]

此条目有帮助吗?