airflow.providers.microsoft.azure.operators.adx¶
此模組包含 Azure Data Explorer 運算子。
模組內容¶
類別¶
用於查詢 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)[原始碼]¶
基底：
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 連線。
- template_fields: collections.abc.Sequence[str] = ('query', 'database')[原始碼]¶
- template_ext: collections.abc.Sequence[str] = ('.kql',)[原始碼]¶
- execute(context)[原始碼]¶
在 Azure Data Explorer (Kusto) 上執行 KQL 查詢。
返回 PrimaryResult 的 Query v2 HTTP 回應內容。
https://docs.microsoft.com/en-us/azure/kusto/api/rest/response2