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

This module contains Azure Data Explorer operators

Module Contents¶

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) -- Azure Data Explorer connection to use.

ui_color = #00a1f2[source]¶

template_fields = ['query', 'database'][source]¶

template_ext = ['.kql'][source]¶

get_hook(self)[source]¶: Returns new instance of AzureDataExplorerHook

execute(self, context: dict)[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¶

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