airflow.providers.microsoft.azure.hooks.msgraph¶

類¶

`DefaultResponseHandler`	DefaultResponseHandler 返回 JSON payload、位元組內容或響應頭。
`KiotaRequestAdapterHook`	一個 Microsoft Graph API 互動 Hook，是 KiotaRequestAdapter 的封裝。

模組內容¶

類 airflow.providers.microsoft.azure.hooks.msgraph.DefaultResponseHandler[source]¶

Bases: kiota_abstractions.response_handler.ResponseHandler

DefaultResponseHandler 返回 JSON payload、位元組內容或響應頭。

靜態 get_value(response)[source]¶

非同步 handle_response_async(response, error_map)[source]¶

接收到響應時呼叫此回撥方法。

param response: 原生響應物件的型別。 param error_map: 請求失敗時使用的錯誤字典。

類 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)[source]¶

Bases: airflow.hooks.base.BaseHook

一個 Microsoft Graph API 互動 Hook，是 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 代理的字典（預設為 None）。
host (str) – 要使用的主機（預設為“https://graph.microsoft.com”）。
scopes (str | list[str] | None) – 要使用的範圍（預設為 ["https://graph.microsoft.com/.default"]）。
api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 版本（預設為 v1）。您可以傳遞一個名為 APIVersion 的列舉，它有兩個可能的成員：v1 和 beta，或者您可以傳遞一個字串，如“v1.0”或“beta”。

DEFAULT_HEADERS[source]¶

DEFAULT_SCOPE = 'https://graph.microsoft.com/.default'[source]¶

cached_request_adapters: dict[str, tuple[msgraph_core.APIVersion, kiota_abstractions.request_adapter.RequestAdapter]][source]¶

conn_type: str = 'msgraph'[source]¶

conn_name_attr: str = 'conn_id'[source]¶

default_conn_name: str = 'msgraph_default'[source]¶

hook_name: str = 'Microsoft Graph API'[source]¶

conn_id = 'msgraph_default'[source]¶

timeout = None[source]¶

proxies = None[source]¶

host = 'https://graph.microsoft.com'[source]¶

類方法 get_connection_form_widgets()[source]¶

返回要新增到連線表單的連線小部件。

類方法 get_ui_field_behaviour()[source]¶

返回自定義欄位行為。

屬性 api_version: str | None[source]¶

靜態 resolve_api_version_from_value(api_version, default=None)[source]¶

get_api_version(config)[source]¶

get_host(connection)[source]¶

靜態 format_no_proxy_url(url)[source]¶

類方法 to_httpx_proxies(proxies)[source]¶

to_msal_proxies(authority, proxies)[source]¶

get_conn()[source]¶

返回此 Hook 的連線。

get_proxies(config)[source]¶

get_credentials(login, password, config, authority, verify, proxies)[source]¶

test_connection()[source]¶: 測試 HTTP 連線。

非同步 run(url='', response_type=None, path_parameters=None, method='GET', query_parameters=None, headers=None, data=None)[source]¶

非同步 send_request(request_info, response_type=None)[source]¶

request_information(url, response_type=None, path_parameters=None, method='GET', query_parameters=None, headers=None, data=None)[source]¶

靜態 normalize_url(url)[source]¶

靜態 encoded_query_parameters(query_parameters)[source]¶

靜態 error_mapping()[source]¶