class_docstr: 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>`.
docstr: 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
docstr_tok: ["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"]
code: def execute(self, context: Context) -> KustoResultTable | str:
      """
      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
      """
      response = self.hook.run_query(
          self.query, self.database, self.options
      )
      if conf.getboolean("core", "enable_xcom_pickling"):
          return response.primary_results[0]
      else:
          return str(response.primary_results[0])
  
file_path: airflow/airflow/providers/microsoft/azure/operators/adx.py
imports: from __future__ import annotations
  from functools import cached_property
  from typing import TYPE_CHECKING, Sequence
  from deprecated.classic import deprecated
  from airflow.configuration import conf
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.models import BaseOperator
  from airflow.providers.microsoft.azure.hooks.adx import AzureDataExplorerHook
label_desc: Use image node_id 4 for calling the AzureDataExplorerQueryOperator obj's underlying member method code with example usage: obj.execute(context) and returns: response, str