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