airflow.providers.microsoft.azure.operators.adx¶

This module contains Azure Data Explorer operators.

Classes¶

AzureDataExplorerQueryOperator

Operator for querying Azure Data Explorer (Kusto).

Module Contents¶

class airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator(*, query, database, options=None, azure_data_explorer_conn_id='azure_data_explorer_default', **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Operator for querying Azure Data Explorer (Kusto).

Parameters:

query (str) – KQL query to run (templated).
database (str) – Database to run the query on (templated).
options (dict | None) – Optional query options. See: https://docs.microsoft.com/en-us/azure/kusto/api/netfx/request-properties#list-of-clientrequestproperties
azure_data_explorer_conn_id (str) – Reference to the Azure Data Explorer connection.

ui_color = '#00a1f2'[source]¶

template_fields: collections.abc.Sequence[str] = ('query', 'database')[source]¶

template_ext: collections.abc.Sequence[str] = ('.kql',)[source]¶

query[source]¶

database[source]¶

options = None[source]¶

azure_data_explorer_conn_id = 'azure_data_explorer_default'[source]¶

property hook: airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook[source]¶

Return new instance of AzureDataExplorerHook.

execute(context)[source]¶

Run KQL Query on Azure Data Explorer (Kusto).

Returns PrimaryResult of Query v2 HTTP response contents.

https://docs.microsoft.com/en-us/azure/kusto/api/rest/response2