airflow_dag_odbc_operator_sql_query_example.py

1from datetime import datetime, timedelta
2from airflow import DAG
3from airflow.providers.odbc.operators.odbc import OdbcOperator
4
5with DAG(
6    dag_id='example_odbc_operator',
7    schedule_interval=None,
8    start_date=datetime(2023, 1, 1),
9    catchup=False,
10    default_args={
11        'retries': 1,
12        'retry_delay': timedelta(minutes=5),
13    },
14) as dag:
15
16    # Example task to execute a SQL command via ODBC
17    # 'odbc_conn_id' should be configured in Airflow Connections
18    execute_sql_task = OdbcOperator(
19        task_id='execute_sql_query',
20        odbc_conn_id='your_odbc_connection',
21        sql='SELECT 1;',
22    )
23
24    execute_sql_task