| 定义方式 | Python 文件（dags 目录自动扫描） |
|---|---|
| 扫描间隔 | dag_dir_list_interval 控制 |
| 关键参数 | dag_id / schedule / start_date / catchup |
| 解析失败 | 文件报错则该 DAG 在界面中不可见 |
最小 DAG 示例
最小 DAG 示例
from datetime import datetime
from airflow import DAG
from airflow.operators.bash import BashOperator
with DAG(
dag_id="daily_orders",
start_date=datetime(2026, 1, 1),
schedule="0 2 * * *",
catchup=False,
tags=["dw"],
) as dag:
extract = BashOperator(task_id="extract", bash_command="echo extract ok")DAG 文件只做声明：不要在文件顶层直接执行拉数逻辑，否则每次扫描解析都会真的跑一次。