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

Uploaded Source

Built Distribution

azure_kusto_ingest-3.1.2-py2.py3-none-any.whl (22.5 kB view details)

Uploaded Python 2 Python 3

File details

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

File metadata

  • Download URL: azure-kusto-ingest-3.1.2.tar.gz
  • Upload date:
  • Size: 16.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.0 CPython/3.7.12

File hashes

Hashes for azure-kusto-ingest-3.1.2.tar.gz
Algorithm Hash digest
SHA256 48afc3e5aa2306a8eda933fa3ec6b63b2e37d5c11b0fc7da6a37684089b04ef2
MD5 2a440f52e7dbf25a4a5ec0d9d7bdac14
BLAKE2b-256 e1c83c3cdd368ce90384925c6068befcd3c3626178420a3e5f45a2b4b494f1fa

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for azure_kusto_ingest-3.1.2-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 d0062b24083f06841942c64aa36a74d7153371f09a86df27a1853f804bc4f072
MD5 f151497fe469cdcaed3bc1fc0b3fe05c
BLAKE2b-256 5e44e87372c294362379d8203be55b4ebd0b2d2f03017abeee5e76e70a4d6cc9

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