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