airflow.providers.microsoft.azure.hooks.adx

此模組包含 Azure Data Explorer Hook。

模組內容

類別

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 叢集 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]

傳回自訂欄位行為。

connection()[source]

傳回 KustoClient 物件 (已快取)。

get_conn()[source]

傳回 KustoClient 物件。

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

使用提供的組態執行 KQL 查詢，並傳回 KustoResponseDataSet 執行個體。

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

參數
傳回

dict

傳回類型

azure.kusto.data.response.KustoResponseDataSetV2

此條目是否有幫助？