airflow.providers.clickhousedb.example_dags.example_clickhouse¶

Example DAG demonstrating SQLExecuteQueryOperator with a ClickHouse connection.

Attributes¶

`CLICKHOUSE_CONN_ID`
`CLICKHOUSE_TABLE`
`create_table`

Module Contents¶

airflow.providers.clickhousedb.example_dags.example_clickhouse.CLICKHOUSE_CONN_ID = 'clickhouse_default'[source]¶

airflow.providers.clickhousedb.example_dags.example_clickhouse.CLICKHOUSE_TABLE = 'airflow_example'[source]¶

airflow.providers.clickhousedb.example_dags.example_clickhouse.create_table[source]¶

Was this entry helpful?