apache-airflow-providers-apache-druid

What it is and what it does

This is an Apache Airflow provider package that bridges Airflow and Apache Druid, enabling you to orchestrate Druid queries and operations as part of your Airflow DAGs. It wraps pydruid and integrates with Airflow's task execution model, allowing you to define Druid-based tasks alongside other data pipeline steps.

The package depends on apache-airflow (>=2.11.0), apache-airflow-providers-common-sql, apache-airflow-providers-common-compat, and pydruid (>=0.6.6). It is actively maintained, supports Python 3.10 through 3.14, and carries no known security vulnerabilities. Installation is straightforward via pip on top of an existing Airflow setup.

Use it for:

• Schedule and monitor Druid SQL queries as part of larger Airflow data pipelines.
• Orchestrate ETL workflows that extract data from Druid and load it into downstream systems.
• Integrate Druid analytics queries into multi-step Airflow DAGs with conditional logic and error handling.
• Manage Druid data ingestion and segment operations through Airflow task scheduling.

Worth the install?

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

Integrates Apache Druid with Apache Airflow, providing operators and hooks to query and manage Druid data sources within Airflow workflows.

Yes, if you run Apache Airflow and need to query or manage Apache Druid. The package is actively maintained, carries no known vulnerabilities, and has low install friction. It is production-stable and widely used. Install only if you have an existing Airflow deployment and a Druid cluster to connect to.

Install

apache-airflow-providers-apache-druid on PyPI

pip install apache-airflow-providers-apache-druid

uv add apache-airflow-providers-apache-druid

poetry add apache-airflow-providers-apache-druid

Installing apache-airflow-providers-apache-druid

Before you install

Low friction install as a pure Python wheel. Actively maintained with recent releases; requires Apache Airflow >=2.11.0 and modern Python (3.10+).

License in practice

Apache-2.0 permissive license allows use in most commercial and open-source projects without significant legal constraints.

Quickstart

pip install apache-airflow-providers-apache-druid

from airflow.providers.apache.druid.operators.druid import DruidOperator

druid_task = DruidOperator(
    task_id='query_druid',
    sql='SELECT * FROM table',
    druid_conn_id='druid_default'
)

Requires an existing Apache Airflow installation (>=2.11.0) and a configured Druid connection in Airflow.

Verify before relying

• Specific operators and hooks available beyond the base integration.
• Whether cross-provider dependencies (apache.hive) are needed for typical use cases.
• Performance characteristics when querying large Druid datasets through Airflow.

Package facts

Evidence: apache_airflow_providers_apache_druid-4.5.2-py3-none-any.whl

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

Tags

More Monitoring packages