Skip to content

kql

sqllocks_spindle.engine.sinks.kql

Classes

KQLSink

Delegate sink that writes chunks to a Fabric Eventhouse (KQL database).

Thin wrapper around :class:~sqllocks_spindle.fabric.EventhouseWriter. Accumulates numpy array chunks as DataFrames per table, then ingests via write() on close.

Requires pip install sqllocks-spindle[fabric-kusto].

Parameters:

Name Type Description Default
cluster_uri str

Eventhouse URI, e.g. https://my-eventhouse.z0.kusto.fabric.microsoft.com.

 required
database str

KQL database name.

 required
auth_method str

"cli", "msi", "spn", or "fabric" (default "cli").

 'cli'
table_prefix str

Optional prefix prepended to every KQL table name.

 ''
batch_size int

Rows per ingestion batch (default 10 000).

 10000
client_id str | None

Service principal client ID (required when auth_method="spn").

 None
client_secret str | None

Service principal secret (required when auth_method="spn").

 None
tenant_id str | None

Azure AD tenant ID (required when auth_method="spn").

 None