airflow.providers.microsoft.azure.operators.adx¶

此模組包含 Azure Data Explorer 運算元。

類¶

AzureDataExplorerQueryOperator

用於查詢 Azure Data Explorer (Kusto) 的運算元。

模組內容¶

class airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator(*, query, database, options=None, azure_data_explorer_conn_id='azure_data_explorer_default', **kwargs)[源]¶

Bases: airflow.models.BaseOperator

用於查詢 Azure Data Explorer (Kusto) 的運算元。

引數：

query (str) – 要執行的 KQL 查詢（模板化）。
database (str) – 執行查詢的資料庫（模板化）。
options (dict | None) – 可選的查詢選項。參見： https://docs.microsoft.com/en-us/azure/kusto/api/netfx/request-properties#list-of-clientrequestproperties
azure_data_explorer_conn_id (str) – 對 Azure Data Explorer connection 的引用。

ui_color = '#00a1f2'[源]¶

template_fields: collections.abc.Sequence[str] = ('query', 'database')[源]¶

template_ext: collections.abc.Sequence[str] = ('.kql',)[源]¶

query[源]¶

database[源]¶

options = None[源]¶

azure_data_explorer_conn_id = 'azure_data_explorer_default'[源]¶

property hook: airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook[源]¶

返回 AzureDataExplorerHook 的新例項。

execute(context)[源]¶

在 Azure Data Explorer (Kusto) 上執行 KQL 查詢。

返回 Query v2 HTTP 響應內容的 PrimaryResult。

https://docs.microsoft.com/en-us/azure/kusto/api/rest/response2