Kusto Ingest客户端
项目描述
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)概述
Kusto Python Ingest Client 库提供了使用 Python 将数据导入 Kusto 集群的功能。它与 Python 3.x 兼容，并通过熟悉的 Python DB API 接口支持数据类型。
可以使用该库，例如，从 Jupyter Notebooks（这些笔记本连接到 Spark 集群，包括但不限于 Azure Databricks 实例）。
下载文件
下载适用于您平台的应用程序。如果您不确定要选择哪个，请了解有关 安装包 的更多信息。
源分布
azure-kusto-ingest-4.6.1.tar.gz (20.8 kB 查看哈希值)
构建分布
关闭
azure-kusto-ingest-4.6.1.tar.gz 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | a49fa459c1e5a55eed8bdcc9ffb51f9c5962aca9aca0905c6e2fa7d08c44d01d |
|
| MD5 | f7c0e904f34211f00a9cafa838957207 |
|
| BLAKE2b-256 | 6f223d07347a7a5f49a1f33066ccd4c265ddba9b076ad2ddc5e7e1cf01df5cee |
关闭
hashes for azure_kusto_ingest-4.6.1-py2.py3-none-any.whl
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | afee994395d83a2847bb4ebd540225e0883690d203a6dee0441624efede2cd96 |
|
| MD5 | c148d699615d2994e738856fd2a56f8f |
|
| BLAKE2b-256 | d14276dca7e002ab01b2131c09fa4301bd1d93f963228e79b70afd8f4ca2a8f9 |