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

This module contains Azure Data Explorer operators

Module Contents¶

Classes¶

AzureDataExplorerQueryOperator

Operator for querying Azure Data Explorer (Kusto).

class airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator(*, query: str, database: str, options: Optional[dict] = None, azure_data_explorer_conn_id: str = '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) -- 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 :Sequence[str] = ['query', 'database'][source]¶

template_ext :Sequence[str] = ['.kql'][source]¶

get_hook(self) → airflow.providers.microsoft.azure.hooks.adx.AzureDataExplorerHook[source]¶: Returns new instance of AzureDataExplorerHook

execute(self, context: airflow.utils.context.Context) → Union[azure.kusto.data._models.KustoResultTable, str][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)

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

Module Contents¶

Classes¶

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