airflow.providers.microsoft.azure.hooks.adx

此模块包含 Azure 数据资源管理器 Hook。

模块内容

类

AzureDataExplorerHook

与 Azure 数据资源管理器 (Kusto) 交互。
class airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook(azure_data_explorer_conn_id=default_conn_name)[源代码]

基类: airflow.hooks.base.BaseHook

与 Azure 数据资源管理器 (Kusto) 交互。

群集:

Azure 数据资源管理器群集由 URL 指定，例如：“https://help.kusto.windows.net”。该参数必须通过数据资源管理器群集 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 数据资源管理器连接的引用。

conn_name_attr = 'azure_data_explorer_conn_id'[源代码]
default_conn_name = 'azure_data_explorer_default'[源代码]
conn_type = 'azure_data_explorer'[源代码]
hook_name = 'Azure Data Explorer'[源代码]
classmethod get_connection_form_widgets()[源代码]

返回要添加到连接表单的连接小部件。

classmethod get_ui_field_behaviour()[源代码]

返回自定义字段行为。

connection()[源代码]

返回一个 KustoClient 对象（已缓存）。

get_conn()[源代码]

返回一个 KustoClient 对象。

run_query(query, database, options=None)[源代码]

使用提供的配置运行 KQL 查询，并返回 KustoResponseDataSet 实例。

请参阅：azure.kusto.data.response.KustoResponseDataSet。如果查询失败，则会引发 AirflowException。

参数
返回

dict

返回类型

azure.kusto.data.response.KustoResponseDataSetV2

此条目是否有帮助？