airflow.providers.microsoft.azure.triggers.msgraph¶

類¶

`ResponseSerializer`	ResponseSerializer 將響應序列化為字串。
`MSGraphTrigger`	一個 Microsoft Graph API trigger，允許你對 Microsoft Graph API 執行非同步 REST 呼叫。

模組內容¶

class airflow.providers.microsoft.azure.triggers.msgraph.ResponseSerializer(encoding=None)[source]¶

ResponseSerializer 將響應序列化為字串。

encoding[source]¶

serialize(response)[source]¶

deserialize(response)[source]¶

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, scopes=None, api_version=None, serializer=ResponseSerializer)[source]¶

基類: airflow.triggers.base.BaseTrigger

一個 Microsoft Graph API trigger，允許你對 Microsoft Graph API 執行非同步 REST 呼叫。

引數:

url (str) – 在 Microsoft Graph API 上執行的 url（模板化）。
response_type (str | None) – 響應的預期返回型別字串。可能的值為: bytes, str, int, float, bool 和 datetime（預設為 None）。
method (str) – 用於執行 REST 呼叫的 HTTP 方法（預設為 GET）。
conn_id (str) – 用於執行 operator 的 HTTP 連線 ID（模板化）。
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.0 或 beta。
serializer (type[ResponseSerializer]) – 處理響應序列化的類（預設為 ResponseSerializer）。Bytes 將被 base64 編碼為字串，以便可以作為 XCom 儲存。

template_fields: collections.abc.Sequence[str] = ('url', 'response_type', 'path_parameters', 'url_template', 'query_parameters', 'headers',...[source]¶