Apache Druid

Allows to submit a task directly to druid

View on GitHub

Last Updated: Oct. 23, 2022

Access Instructions

Install the Apache Druid provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


json_index_fileRequiredThe filepath to the druid index specification
druid_ingest_conn_idThe connection id of the Druid overlord which accepts index jobs
timeoutThe interval (in seconds) between polling the Druid job for the status of the ingestion job. Must be greater than or equal to 1
max_ingestion_timeThe maximum ingestion time before assuming the job failed


Allows to submit a task directly to druid

Was this page helpful?