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

Uploaded Source

Built Distribution

azure_kusto_ingest-4.1.2-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.2.tar.gz.

File metadata

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

File hashes

Hashes for azure-kusto-ingest-4.1.2.tar.gz
Algorithm Hash digest
SHA256 ceda60017ddef3c694025b9b1631b20c70964456d0aec0cbc628a979922613cb
MD5 f07b7e23589cac666a1a54456cbba356
BLAKE2b-256 98ee08c73278a164a07e458220e199a153b3ed65c7139dd70015020671aa5127

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for azure_kusto_ingest-4.1.2-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 4f5cf579ecdd26b44ce92b8bcd9f3ec4c5bd92dda5de8c28f174bee21512f03a
MD5 ac903f4eaf61e7582bc2f10577724385
BLAKE2b-256 fcd0c08b699df86f2b699457f5f077e0d6c29a4bed97afdf00829515cd493eab

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