airflow.providers.microsoft.azure.hooks.adx¶

此模組包含 Azure Data Explorer 鉤子。

類¶

AzureDataExplorerHook

與 Azure Data Explorer (Kusto) 互動。

模組內容¶

class airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook(azure_data_explorer_conn_id=default_conn_name)[source]¶

基類: airflow.hooks.base.BaseHook

與 Azure Data Explorer (Kusto) 互動。

叢集:

Azure Data Explorer 叢集由 URL 指定，例如：“https://help.kusto.windows.net”。該引數必須透過 Data Explorer Cluster URL 連線詳情提供。

租戶 ID:

要了解租戶，請參閱：https://docs.microsoft.com/en-us/onedrive/find-your-office-365-tenant-id

身份驗證方法:

可用的身份驗證方法有

AAD_APP：使用 AAD 應用程式證書進行身份驗證。使用此方法時需要租戶 ID。透過“使用者名稱”和“密碼”引數提供應用程式 ID 和應用程式金鑰。

AAD_APP_CERT：使用 AAD 應用程式證書進行身份驗證。使用此方法時需要租戶 ID、應用程式 PEM 證書和應用程式證書指紋。

AAD_CREDS：使用 AAD 使用者名稱和密碼進行身份驗證。使用此方法時需要租戶 ID。“使用者名稱”和“密碼”引數用於與 AAD 進行身份驗證。

AAD_DEVICE：使用 AAD 裝置程式碼進行身份驗證。請注意，如果選擇此選項，您需要為每個新初始化的例項進行身份驗證。強烈建議建立一個例項並將其用於所有查詢。

引數：: azure_data_explorer_conn_id (str) – 對 Azure Data Explorer 連線的引用。

conn_name_attr = 'azure_data_explorer_conn_id'[source]¶

default_conn_name = 'azure_data_explorer_default'[source]¶

conn_type = 'azure_data_explorer'[source]¶

hook_name = 'Azure Data Explorer'[source]¶

classmethod get_connection_form_widgets()[source]¶

返回連線小部件以新增到連線表單。

classmethod get_ui_field_behaviour()[source]¶

返回自定義欄位行為。

conn_id = 'azure_data_explorer_default'[source]¶

property connection: azure.kusto.data.KustoClient[source]¶

返回一個 KustoClient 物件（已快取）。

get_conn()[source]¶

返回一個 KustoClient 物件。

run_query(query, database, options=None)[source]¶

使用提供的配置執行 KQL 查詢，並返回 KustoResponseDataSet 例項。

參見：azure.kusto.data.response.KustoResponseDataSet 如果查詢不成功，則會引發 AirflowException。

引數：

query (str) – 要執行的 KQL 查詢
database (str) – 執行查詢的資料庫。
options (dict | None) – 可選查詢選項。參見：https://docs.microsoft.com/en-us/azure/kusto/api/netfx/request-properties#list-of-clientrequestproperties

返回：

dict

返回型別：

azure.kusto.data.response.KustoResponseDataSet