Skip to main content

Kusto Data Client

Project description

from azure.kusto.data import KustoClient, KustoConnectionStringBuilder

cluster = "<insert here your cluster name>"
client_id = "<insert here your AAD application id>"
client_secret = "<insert here your AAD application key>"
authority_id = "<insert here your AAD tenant id>"

kcsb = KustoConnectionStringBuilder.with_aad_application_key_authentication(cluster, client_id, client_secret, authority_id)
client = KustoClient(kcsb)

db = "Samples"
query = "StormEvents | take 10"

response = client.execute(db, query)
for row in response.primary_results[0]:
    print(row[0], " ", row["EventType"])

Kusto Python Client Library provides the capability to query Kusto clusters using Python. It is Python 3.x compatible and supports all data types through familiar Python DB API interface.

It’s possible to use the library, for instance, from Jupyter Notebooks. which are attached to Spark clusters, including, but not exclusively, Azure Databricks. instances.

Async Client

Kusto now provides an asynchronous client for queries.

To use the client, first install the package with the “aio” extra:

pip install azure-kusto-data[aio]

The async client uses exact same interface as the regular client, except that it lives in the azure.kusto.data.aio namespace, and it returns Futures you will need to await its

from azure.kusto.data import KustoConnectionStringBuilder
from azure.kusto.data.aio import KustoClient

cluster = "<insert here your cluster name>"
client_id = "<insert here your AAD application id>"
client_secret = "<insert here your AAD application key>"
authority_id = "<insert here your AAD tenant id>"


async def sample():
    kcsb = KustoConnectionStringBuilder.with_aad_application_key_authentication(cluster, client_id, client_secret, authority_id)
    async with KustoClient(kcsb) as client:
        db = "Samples"
        query = "StormEvents | take 10"

        response = await client.execute(db, query)
        for row in response.primary_results[0]:
            print(row[0], " ", row["EventType"])

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

azure-kusto-data-3.0.0.tar.gz (35.4 kB view details)

Uploaded Source

Built Distribution

azure_kusto_data-3.0.0-py2.py3-none-any.whl (42.3 kB view details)

Uploaded Python 2 Python 3

File details

Details for the file azure-kusto-data-3.0.0.tar.gz.

File metadata

  • Download URL: azure-kusto-data-3.0.0.tar.gz
  • Upload date:
  • Size: 35.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.7.1 importlib_metadata/4.10.0 pkginfo/1.8.2 requests/2.27.1 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.7.12

File hashes

Hashes for azure-kusto-data-3.0.0.tar.gz
Algorithm Hash digest
SHA256 f95f848cdf501c7cfacb262b17687198f71cab80a1b186cb23a56849dd1b00a4
MD5 7be712becb4a1fda3935b19e9de54555
BLAKE2b-256 959a9a940f3b560ab100d3400f01453fe9c929db1a0203c4dcb8a97c61a90030

See more details on using hashes here.

File details

Details for the file azure_kusto_data-3.0.0-py2.py3-none-any.whl.

File metadata

  • Download URL: azure_kusto_data-3.0.0-py2.py3-none-any.whl
  • Upload date:
  • Size: 42.3 kB
  • Tags: Python 2, Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.7.1 importlib_metadata/4.10.0 pkginfo/1.8.2 requests/2.27.1 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.7.12

File hashes

Hashes for azure_kusto_data-3.0.0-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 8238e7283e66cc2b80408b8f546739a6ab89e04691642ed1a78b1890dce714c8
MD5 2c54386ee47e30cc69f07e2f12b32b9a
BLAKE2b-256 14c43980b7a0987317ba34556284c61b85177a4bd81d9e646609e0877b140ba9

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page