airflow.providers.microsoft.azure.hooks.msgraph

模組內容

類別

DefaultResponseHandler

DefaultResponseHandler 傳回 JSON 酬載或位元組內容或回應標頭。

KiotaRequestAdapterHook

Microsoft Graph API 互動 Hook，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 互動 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 (list[str] | None) – 要使用的範圍（預設為 [“https://graph.microsoft.com/.default”]）。

  • api_version (msgraph_core.APIVersion | str | None) – 要使用的 Microsoft Graph API 的 API 版本（預設為 v1）。您可以傳遞一個名為 APIVersion 的列舉，其中有 2 個可能的成員 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)[原始碼]
get_api_version(config)[原始碼]
get_host(connection)[原始碼]
static format_no_proxy_url(url)[原始碼]
classmethod to_httpx_proxies(proxies)[原始碼]
to_msal_proxies(authority, proxies)[原始碼]
get_conn()[原始碼]

傳回 Hook 的連線。

test_connection()[原始碼]

測試 HTTP 連線。

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

這個條目有幫助嗎？