| :py:mod:`airflow.providers.microsoft.azure.operators.adx` |
| ========================================================= |
| |
| .. py:module:: airflow.providers.microsoft.azure.operators.adx |
| |
| .. autoapi-nested-parse:: |
| |
| This module contains Azure Data Explorer operators |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.microsoft.azure.operators.adx.AzureDataExplorerQueryOperator |
| |
| |
| |
| |
| .. py:class:: AzureDataExplorerQueryOperator(*, query, database, options = None, azure_data_explorer_conn_id = 'azure_data_explorer_default', **kwargs) |
| |
| Bases: :py:obj:`airflow.models.BaseOperator` |
| |
| Operator for querying Azure Data Explorer (Kusto). |
| |
| :param query: KQL query to run (templated). |
| :param database: Database to run the query on (templated). |
| :param options: Optional query options. See: |
| https://docs.microsoft.com/en-us/azure/kusto/api/netfx/request-properties#list-of-clientrequestproperties |
| :param azure_data_explorer_conn_id: Reference to the |
| :ref:`Azure Data Explorer connection<howto/connection:adx>`. |
| |
| .. py:attribute:: ui_color |
| :annotation: = #00a1f2 |
| |
| |
| |
| .. py:attribute:: template_fields |
| :annotation: :Sequence[str] = ['query', 'database'] |
| |
| |
| |
| .. py:attribute:: template_ext |
| :annotation: :Sequence[str] = ['.kql'] |
| |
| |
| |
| .. py:method:: get_hook(self) |
| |
| Returns new instance of AzureDataExplorerHook |
| |
| |
| .. py:method:: execute(self, context) |
| |
| 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) |
| |
| |
| |