Skip to main content

Kusto Ingest Client

Project description

from azure.kusto.data import KustoConnectionStringBuilder, DataFormat
from azure.kusto.ingest import QueuedIngestClient, IngestionProperties, FileDescriptor, BlobDescriptor

ingestion_props = IngestionProperties(database="{database_name}", table="{table_name}", data_format=DataFormat.CSV)
client = QueuedIngestClient(KustoConnectionStringBuilder.with_interactive_login("https://ingest-{cluster_name}.kusto.windows.net"))

file_descriptor = FileDescriptor("{filename}.csv", 15360)  # in this example, the raw (uncompressed) size of the data is 15KB (15360 bytes)
client.ingest_from_file(file_descriptor, ingestion_properties=ingestion_props)
client.ingest_from_file("{filename}.csv", ingestion_properties=ingestion_props)

blob_descriptor = BlobDescriptor("https://{path_to_blob}.csv.gz?sas", 51200)  # in this example, the raw (uncompressed) size of the data is 50KB (52100 bytes)
client.ingest_from_blob(blob_descriptor, ingestion_properties=ingestion_props)

Overview

Kusto Python Ingest Client Library provides the capability to ingest data into Kusto clusters using Python. It is Python 3.x compatible and supports 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.

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-ingest-4.1.3.tar.gz (18.4 kB view details)

Uploaded Source

Built Distribution

azure_kusto_ingest-4.1.3-py2.py3-none-any.whl (25.3 kB view details)

Uploaded Python 2 Python 3

File details

Details for the file azure-kusto-ingest-4.1.3.tar.gz.

File metadata

  • Download URL: azure-kusto-ingest-4.1.3.tar.gz
  • Upload date:
  • Size: 18.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.2 CPython/3.7.16

File hashes

Hashes for azure-kusto-ingest-4.1.3.tar.gz
Algorithm Hash digest
SHA256 0f9f0ad58ce4cabf0169738a225a7068a1a619afd0a58e81e2e64809c53ecdc2
MD5 5a643b8bead82caf10a6e5ef34e4f2c1
BLAKE2b-256 fda69f37103cf54c224a00a9ce91ba86616c897b1b9bf512c80d423d9238ae49

See more details on using hashes here.

File details

Details for the file azure_kusto_ingest-4.1.3-py2.py3-none-any.whl.

File metadata

File hashes

Hashes for azure_kusto_ingest-4.1.3-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 6f11ba8794592d6bf8d52fabdb7352c7888b565144ff84817938f33451826856
MD5 9c2b910dd482a286d7459c57f64d9e39
BLAKE2b-256 e6e5a0593d6c14914d16ffd78b77999482ac6a15074afc64d829990446076039

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