18 lines
552 B
Python
18 lines
552 B
Python
from airflow import DAG
|
|
from airflow.operators.python import PythonOperator
|
|
from airflow_clickhouse_plugin.hooks.clickhouse import ClickHouseHook
|
|
from datetime import datetime
|
|
|
|
def test_conn():
|
|
hook = ClickHouseHook(clickhouse_conn_id="my_clickhouse_provider")
|
|
result = hook.get_conn().execute("SELECT * FROM test_repl;")
|
|
print(result)
|
|
|
|
with DAG(
|
|
dag_id="test_clickhouse_dag",
|
|
start_date=datetime(2024, 1, 1),
|
|
schedule=None,
|
|
catchup=False,
|
|
) as dag:
|
|
PythonOperator(task_id="check_clickhouse", python_callable=test_conn)
|