airflow.providers.microsoft.azure.hooks.msgraph

模块内容

DefaultResponseHandler

DefaultResponseHandler 返回 JSON 载荷或字节内容或响应头。

KiotaRequestAdapterHook

Microsoft Graph API 交互钩子,KiotaRequestAdapter 的包装器。

class airflow.providers.microsoft.azure.hooks.msgraph.DefaultResponseHandler[源代码]

基类: kiota_abstractions.response_handler.ResponseHandler

DefaultResponseHandler 返回 JSON 载荷或字节内容或响应头。

static get_value(response)[源代码]
async handle_response_async(response, error_map=None)[源代码]

当收到响应时调用此回调方法。

param response: 原生响应对象的类型。 param error_map: 在请求失败时使用的错误字典。

class airflow.providers.microsoft.azure.hooks.msgraph.KiotaRequestAdapterHook(conn_id=default_conn_name, timeout=None, proxies=None, host=NationalClouds.Global.value, scopes=None, api_version=None)[源代码]

基类: airflow.hooks.base.BaseHook

Microsoft Graph API 交互钩子,KiotaRequestAdapter 的包装器。

https://github.com/microsoftgraph/msgraph-sdk-python-core

参数
  • conn_id (str) – 要运行触发器的 HTTP 连接 ID。

  • timeout (float | None) – KiotaRequestAdapter 使用的 HTTP 超时(默认为 None)。 当未指定超时或设置为 None 时,不会对每个请求应用 HTTP 超时。

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

  • host (str) – 要使用的主机(默认为 “https://graph.microsoft.com”)。

  • scopes (list[str] | None) – 要使用的范围(默认为 [“https://graph.microsoft.com/.default”])。

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

property api_version: str | None[源代码]
DEFAULT_HEADERS[源代码]
cached_request_adapters: dict[str, tuple[msgraph_core.APIVersion, kiota_abstractions.request_adapter.RequestAdapter]][源代码]
conn_type: str = 'msgraph'[源代码]
conn_name_attr: str = 'conn_id'[源代码]
default_conn_name: str = 'msgraph_default'[源代码]
hook_name: str = 'Microsoft Graph API'[源代码]
classmethod get_connection_form_widgets()[源代码]

返回要添加到连接表单的连接小部件。

classmethod get_ui_field_behaviour()[源代码]

返回自定义字段行为。

static resolve_api_version_from_value(api_version, default=None)[source]
get_api_version(config)[source]
get_host(connection)[source]
static format_no_proxy_url(url)[source]
classmethod to_httpx_proxies(proxies)[source]
to_msal_proxies(authority, proxies)[source]
get_conn()[source]

返回 hook 的连接。

test_connection()[source]

测试 HTTP 连接。

async run(url='', response_type=None, path_parameters=None, method='GET', query_parameters=None, headers=None, data=None)[source]
request_information(url, response_type=None, path_parameters=None, method='GET', query_parameters=None, headers=None, data=None)[source]
static normalize_url(url)[source]
static encoded_query_parameters(query_parameters)[source]
static error_mapping()[source]

此条目是否有帮助?