首页/数据/数据工程与 ETL 速查/DAG 版本管理与发布
本包目录(311 条)

DAG 版本管理与发布

DAG 代码进 Git 走评审发布:保持 dag_id 与 task_id 稳定、用增量方式演进,回滚时能定位哪个版本从哪一刻生效,避免在生产目录手改文件。

代码托管Git 仓库加 MR 评审
发布git-sync 或 CI 推送 dags 目录
兼容策略dag_id 稳定,新增任务而不是改名
回滚按 commit 回退 DAG 文件

发布与回滚示意

发布与回滚示意
git tag dag-release-2026.10.12
# CI 校验 DagBag 通过后同步到调度环境
git checkout dag-release-2026.10.11 -- dags/daily_orders.py
给 DAG 文件记录 owner 与变更原因;DAG 数量一多,靠记忆回溯成本很高。

易错点

  • 直接在生产 dags 目录手改文件,出问题无版本可回退
  • 大改 task_id 后重跑语义混乱,历史口径对不上

数据来源与参考

  • Apache Airflow 官方文档(DAG Best Practices)
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌