kustopy 1.0.10

Use Azure Kusto Data and Azure Kusto Ingest in Python

pip install kustopy

The package includes the functionality to query and to ingest data.

Query

Frist load the query function from kustopy

from kustopy import query

Then set up the client

query_client = query.create_engine(cluster, client_id, client_secret, tenant_id)

For EY on databricks we can get the credentials as

cluster = 'sample01.westeurope'
client_id = dbutils.secrets.get(scope="ce5", key="adxClientId")
client_secret = dbutils.secrets.get(scope="ce5", key="adxClientSecret")
tenant_id = dbutils.secrets.get(scope="ce5", key="adxTenantId")

query_client = query.create_engine(cluster, client_id, client_secret, tenant_id)

Finally we can query the database and get the result into a pandas dataframe

database = 'sample-db'
query.get_pdf(user_input='SampleTable | take 10', 
              client=query_client, 
              database=database, 
              truncation=True)