airflow-clickhouse-plugin
airflow-clickhouse-plugin — Airflow plugin to execute ClickHouse commands and queries
Decision gist · record as of 2026-08-14
Yes. The plugin is actively maintained, has no known vulnerabilities, low install friction, and permissive licensing. It fills a clear need for ClickHouse integration in Airflow with two well-documented operator families. Install it if you run Airflow >=2.3.0 with Python >=3.10 and need to query or load ClickHouse from DAGs.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires an Airflow connection named 'clickhouse_default' (or custom conn_id) configured with ClickHouse host, port, user, and password; Airflow >=2.3.0 and Python >=3.10 for version 1.8.0.
- Low install friction; pure Python wheel with only two runtime dependencies (apache-airflow and clickhouse-driver).
- Active maintenance with a release 32 days ago and 184 repository stars.
License · maintenance · safety
MIT License (permissive) — MIT License permits commercial and private use with minimal restrictions; no copyleft obligations or patent clauses.
last release 2026-07-13 (32 days) · last repo commit 2026-08-03 · 184 stars
0 known vulnerabilities (OSV.dev, 2026-08-14) · 666,777 downloads/mo, #5,424 on PyPI
Alternatives
Verify before relying
pip install airflow-clickhouse-plugin
from airflow_clickhouse_plugin.operators.clickhouse import ClickHouseOperator
task = ClickHouseOperator(
task_id='query_clickhouse',
sql='SELECT count() FROM my_table',
clickhouse_conn_id='clickhouse_default'
)- Whether the plugin's OpenLineage integration (via optional openlineage extra) is production-ready and actively maintained.
- Performance characteristics when executing very large result sets or high-frequency query patterns.
- Compatibility with Airflow 3.4.0+ given the version table shows support only up to <3.4.0.
What it is and what it does
This is an Apache Airflow plugin that wraps clickhouse-driver to let you define ClickHouse queries as Airflow tasks. It offers two operator families: one based directly on clickhouse-driver's Client.execute (ClickHouseOperator, ClickHouseHook, ClickHouseSensor) for full native protocol support, and a second family (ClickHouseSQLExecuteQueryOperator and related operators) that implements the Python DB API 2.0 standard for compatibility with other SQL providers in Airflow.
The native-protocol operators support SQL templating, multiple queries per task, query logging, and custom connection parameters like compression and timeouts. The DB API 2.0 operators provide a standardized interface useful when migrating Airflow pipelines from other databases to ClickHouse. Both families are tested across multiple Python and Airflow versions. The plugin requires Airflow >=2.3.0 and Python >=3.10 for version 1.8.0.
Use it for
- Define ClickHouse data transformations and loads as Airflow DAG tasks with SQL templating and XCom result passing.
- Migrate existing Airflow pipelines from MySQL, Postgres, or BigQuery to ClickHouse using DB API 2.0 operators.
- Monitor ClickHouse query results or table state changes using ClickHouseSensor or ClickHouseSqlSensor in task dependencies.
- Execute multi-statement ClickHouse scripts within a single task, with the final query result automatically pushed to XCom.
- Integrate ClickHouse operations with OpenLineage for data lineage tracking in Airflow 2.7.0+.
Worth the install?
AI-flagged interpretation of the facts on this page. Verify before relying on it.
Yes.
The plugin is actively maintained, has no known vulnerabilities, low install friction, and permissive licensing. It fills a clear need for ClickHouse integration in Airflow with two well-documented operator families. Install it if you run Airflow >=2.3.0 with Python >=3.10 and need to query or load ClickHouse from DAGs.
Install
airflow-clickhouse-plugin on PyPI
Before you install
Low install friction; pure Python wheel with only two runtime dependencies (apache-airflow and clickhouse-driver). Active maintenance with a release 32 days ago and 184 repository stars.
Requires an Airflow connection named 'clickhouse_default' (or custom conn_id) configured with ClickHouse host, port, user, and password; Airflow >=2.3.0 and Python >=3.10 for version 1.8.0.
License in practice
MIT License permits commercial and private use with minimal restrictions; no copyleft obligations or patent clauses.
Quickstart
pip install airflow-clickhouse-plugin
from airflow_clickhouse_plugin.operators.clickhouse import ClickHouseOperator
task = ClickHouseOperator(
task_id='query_clickhouse',
sql='SELECT count() FROM my_table',
clickhouse_conn_id='clickhouse_default'
)Verify before relying
- Whether the plugin's OpenLineage integration (via optional openlineage extra) is production-ready and actively maintained.
- Performance characteristics when executing very large result sets or high-frequency query patterns.
- Compatibility with Airflow 3.4.0+ given the version table shows support only up to <3.4.0.
Package facts
| License | MIT License permissive |
| Python support | Supports the current Python release >=3.10 |
| Install friction | Low. Pure-Python wheel |
| Runtime dependencies | 2 packagesapache-airflowclickhouse-driver |
| Maintenance | Actively maintained 32 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 666,777 / month, #5,424 on PyPI 30-day window, as of 2026-08-14 |
| Known vulnerabilities | None known OSV.dev, checked 2026-08-14 |
| Classifiers | Development Status :: 5 - Production/StableEnvironment :: PluginsIntended Audience :: DevelopersProgramming Language :: Python :: 3.10Programming Language :: Python :: 3.11Programming Language :: Python :: 3.12Programming Language :: Python :: 3.13Programming Language :: Python :: 3.14 |
Evidence: airflow_clickhouse_plugin-1.8.0-py3-none-any.whl
Tags
Let your AI agent find packages like this
Example. Real query, live index.
You found this page by searching. An agent finds it by wishing: SkillFed indexes 14,416 PyPI packages by what they can do, searchable in plain language.
wish › “airflow clickhouse operator”
- airflow-clickhouse-pluginProvides Apache Airflow operators and hooks to execute SQL queries…
- airflow-powerbi-pluginAn Apache Airflow plugin that triggers Power BI dataset refreshes via…
- apache-airflow-providers-sambaIntegrates Samba file-sharing protocol with Apache Airflow, enabling…
Give your agent the search over MCP, or paste the wish link into any chat.
More Database packages
psycopg2-binary is a PostgreSQL database adapter for Python that implements the DB API 2.0 specification, enabling Python applications to connect to and query PostgreSQL databases with thread-safe concurrent operations.
Python client library for connecting to and executing commands against Redis key-value stores, supporting both synchronous and asynchronous operations.
Install it if your application needs to interact with Redis; the only prerequisite is a running Redis server instance.
YDB Python SDK is the official client library for connecting to and querying YDB databases from Python applications.
Install it if you need to connect Python applications to YDB databases.
Connects Python applications to Snowflake data warehouses using the DB API 2.0 specification, enabling SQL queries, data transfers, and warehouse operations.
sqlparse tokenizes SQL text into a tree of statements, clauses, and expressions, and provides functions to split scripts, format queries, and inspect parsed tokens without validating dialect or syntax.
Install it if you need to manipulate, format, or analyze SQL text programmatically.
Provides base adapter protocols and shared functionality that database adapters use to integrate with dbt-core, handling connections, dialect translation, relation caching, and core interface management.
See also apache-airflow-providers-common-sql · apache-airflow-providers-microsoft-mssql · apache-airflow-providers-mysql · apache-airflow-providers-odbc · apache-airflow-providers-oracle · clickhouse-driver · apache-airflow-providers-apache-drill · apache-airflow-providers-databricks · apache-airflow-providers-informatica · aiochclient