apache-airflow-providers-apache-cassandra

What it is and what it does

This is an Apache Airflow provider package that bridges Airflow DAGs and Apache Cassandra clusters. It supplies operators and hooks—the core building blocks for Airflow tasks—that let you execute CQL queries, read and write data, and manage Cassandra operations as part of your data pipeline orchestration. The package depends on apache-airflow (2.11.0 or later), cassandra-driver, and apache-airflow-providers-common-compat, and is maintained as part of the official Apache Airflow project.

You install it on top of an existing Airflow environment to add Cassandra connectivity. It supports Python 3.10 through 3.13, with cassandra-driver version pinned per Python release. The package is actively maintained, with no known security vulnerabilities, and carries a permissive Apache 2.0 license suitable for commercial use.

Use it for:

• Schedule and execute CQL queries against a Cassandra cluster on a recurring basis as part of an Airflow DAG.
• Load data from Cassandra into downstream systems (data warehouses, lakes) as an ETL step in a larger pipeline.
• Insert or update records in Cassandra as the final step of a multi-stage data transformation workflow.
• Monitor Cassandra table health or row counts by querying the cluster on a schedule and alerting on anomalies.
• Coordinate complex multi-step workflows that involve both Cassandra and other data sources or services via Airflow orchestration.

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Integrates Apache Cassandra with Apache Airflow, providing operators and hooks to query, insert, and manage data in Cassandra clusters from Airflow DAGs.

Yes. This is an official Apache Airflow provider maintained by the Apache project, actively released, with no security vulnerabilities, low install friction, and a permissive license. Install it if you run Airflow and need to orchestrate Cassandra workloads; it is the standard integration for that use case. Ensure your Airflow version is 2.11.0 or later and your Python version is 3.10–3.13.

Install

apache-airflow-providers-apache-cassandra on PyPI

pip install apache-airflow-providers-apache-cassandra

uv add apache-airflow-providers-apache-cassandra

poetry add apache-airflow-providers-apache-cassandra

Installing apache-airflow-providers-apache-cassandra

Before you install

Low friction installation as a pure-Python wheel. Actively maintained with recent releases; requires Airflow 2.11.0 or later and cassandra-driver with version constraints tied to Python version.

License in practice

Apache License 2.0 (permissive) allows commercial use, modification, and distribution with minimal restrictions.

Quickstart

pip install apache-airflow-providers-apache-cassandra

from airflow.providers.apache.cassandra.operators.cassandra import CassandraOperator
from airflow import DAG

with DAG('cassandra_dag') as dag:
    task = CassandraOperator(task_id='query', cql='SELECT * FROM table')

Requires Apache Airflow 2.11.0 or later; Python 3.10–3.13 only; cassandra-driver version depends on Python version (3.29.3 for Python 3.13, 3.29.2 for 3.12, 3.29.1 for earlier versions).

Verify before relying

• Whether the package includes connection types, sensors, or transfer operators beyond basic operators and hooks.
• Whether Cassandra cluster authentication (username/password, SSL/TLS) is handled by the provider or delegated to cassandra-driver.
• Performance characteristics or limitations when working with large result sets or high-throughput workloads.

Package facts

Evidence: apache_airflow_providers_apache_cassandra-3.9.5-py3-none-any.whl

Keywords: airflow-provider, apache.cassandra, airflow, integration

Tags

More Monitoring packages