Skip to main content

Kusto Data Client

Project description

Microsoft Azure Kusto Library for Python

Overview

.. code-block:: python

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 <http://jupyter.org/>. which are attached to Spark clusters, including, but not exclusively, Azure Databricks <https://azure.microsoft.com/en-us/services/databricks/>. instances.

Async Client

Kusto now provides an asynchronous client for queries.

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

.. code:: bash

    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

.. code:: python

    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"])

Links
~~~~~

* `How to install the package <https://github.com/Azure/azure-kusto-python#install>`_.

* `Kusto query sample <https://github.com/Azure/azure-kusto-python/blob/master/azure-kusto-data/tests/sample.py>`_.

* `GitHub Repository <https://github.com/Azure/azure-kusto-python/tree/master/azure-kusto-data>`_.


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-5.0.4.tar.gz (43.6 kB view details)

Uploaded Source

Built Distribution

azure_kusto_data-5.0.4-py2.py3-none-any.whl (52.4 kB view details)

Uploaded Python 2Python 3

File details

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

File metadata

  • Download URL: azure-kusto-data-5.0.4.tar.gz
  • Upload date:
  • Size: 43.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.12.9

File hashes

Hashes for azure-kusto-data-5.0.4.tar.gz
Algorithm Hash digest
SHA256 15f4e3a1c585387c283984bfccd3b7fb08e752ff83fbb12526179c5478b4c385
MD5 8d10219232397786861b7431f177d217
BLAKE2b-256 45691fdda89a444c22d4927ae2036ea56068947cb835b6d6e8cbb9b2eddfdab7

See more details on using hashes here.

Provenance

The following attestation bundles were made for azure-kusto-data-5.0.4.tar.gz:

Publisher: release.yml on Azure/azure-kusto-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

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

File metadata

File hashes

Hashes for azure_kusto_data-5.0.4-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 84609543c35904ed1c97f27549328fe2b7cc75f8f32f599dac89f91a5a22f22c
MD5 3bec3b92a94e64d664c2e1039e5632cf
BLAKE2b-256 bb360fe3066a1f3315c6beff158b78fe5a0288d0c5f8f40016e14078476d1146

See more details on using hashes here.

Provenance

The following attestation bundles were made for azure_kusto_data-5.0.4-py2.py3-none-any.whl:

Publisher: release.yml on Azure/azure-kusto-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

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