airflow.providers.microsoft.azure.operators.adx¶
此模块包含 Azure 数据资源管理器操作符。
模块内容¶
类¶
用于查询 Azure 数据资源管理器 (Kusto) 的操作符。 |
- class airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator(*, query, database, options=None, azure_data_explorer_conn_id='azure_data_explorer_default', **kwargs)[源代码]¶
基类:
airflow.models.BaseOperator用于查询 Azure 数据资源管理器 (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 数据资源管理器连接。
- template_fields: collections.abc.Sequence[str] = ('query', 'database')[源代码]¶
- template_ext: collections.abc.Sequence[str] = ('.kql',)[源代码]¶
- execute(context)[源代码]¶
在 Azure 数据资源管理器 (Kusto) 上运行 KQL 查询。
返回查询 v2 HTTP 响应内容的 PrimaryResult。
https://docs.microsoft.com/en-us/azure/kusto/api/rest/response2