Clickhouse | Kestra

Clickhouse
Certified
Tasks that connect to ClickHouse via JDBC, run clickhouse-local CLI commands, or run embedded ChDB SQL transforms.

Provide the ClickHouse JDBC URL, credentials, and SQL statements (query, batch, load, trigger) to read or write data; configure fetch type, fetch size, and output options to return rows or files from workflows. Use ChDB for a single embedded SQL transform with managed Ion or file output (no server). Use ClickHouseLocalCLI for arbitrary clickhouse-local commands.

tasks

BulkInsert

Bulk insert rows into ClickHouse with JDBC batch

io.kestra.plugin.jdbc.clickhouse.BulkInsert

ChDB

Query data with embedded ClickHouse (chDB)

io.kestra.plugin.jdbc.clickhouse.ChDB

ClickHouseLocalCLI

Run clickhouse-local CLI commands

io.kestra.plugin.jdbc.clickhouse.ClickHouseLocalCLI

Queries

Execute multiple SQL statements against ClickHouse

io.kestra.plugin.jdbc.clickhouse.Queries

Query

Execute a single SQL query against ClickHouse

io.kestra.plugin.jdbc.clickhouse.Query

triggers

Trigger

Wait for query results on ClickHouse and trigger flow

io.kestra.plugin.jdbc.clickhouse.Trigger

ClickHouse real-time event ingestion with TTL-driven cleanup

Ingest data to and query data from ClickHouse

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Dataform

Tasks that run Dataform data transformations through the Dataform CLI.