Skip to main content

Kusto Data Client

Reason this release was yanked:

Broken

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)
# It is a good practice to re-use the KustoClient instance, as it maintains a pool of connections to the Kusto service.
# This sample shows how to create a client and close it in the same scope, for demonstration purposes.
with KustoClient(kcsb) as client:
    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-4.6.0.tar.gz (41.1 kB view details)

Uploaded Source

Built Distribution

azure_kusto_data-4.6.0-py2.py3-none-any.whl (51.1 kB view details)

Uploaded Python 2 Python 3

File details

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

File metadata

  • Download URL: azure-kusto-data-4.6.0.tar.gz
  • Upload date:
  • Size: 41.1 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/5.1.1 CPython/3.12.6

File hashes

Hashes for azure-kusto-data-4.6.0.tar.gz
Algorithm Hash digest
SHA256 06ee1081a7e0c7d5adaac4e1e6cc5c93a2a9eef73eb7e255e83e08f56ce18b80
MD5 d00d027434b3fcb001a0394a5bf1c55f
BLAKE2b-256 0c79594e8b3114d4049f0ffe94204a0d3d98217f4c2facaf40d51ca3401e79dd

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for azure_kusto_data-4.6.0-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 0a658f7e246c034f5a7f6e329c8c5d391d4459c3711ea36214a6a183d54e0a94
MD5 008cd127f9cf630be5bcd5dc27caa247
BLAKE2b-256 253e4dad38a6c359890c60f0aed35d4a72d7bea49499855c443d457c216da256

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