Step by step

Airflow 工作流练习集
使用指南

一组按主题拆分的 Airflow DAG 示例,覆盖基础任务、TaskFlow ETL、分支与短路、动态映射、任务组、资产生产消费及可延迟传感器。适合在自己的学习环境中阅读任务依赖与执行状态,不是直接承接生产数据的调度服务。

准备好这些

  • 与示例 API 兼容的 Airflow 3 学习环境
  • 可访问的本地 Airflow 管理界面
  • 用于练习的独立元数据库
以下步骤以项目当前整理的代码与文档为依据。外部平台和业务系统可能发生变化;完整限制见项目详情。

操作步骤

  1. 先看基础 DAG

    从 demo00 基础示例阅读任务名称、依赖与执行顺序,避免一次启用全部练习。

  2. 导入学习环境

    按自己的 Airflow 配置将示例放入 DAG 搜索目录,检查导入错误和依赖缺失。

  3. 手动触发一次

    在管理界面启用并触发基础示例,查看图视图、任务状态和日志。

  4. 逐个比较主题

    再学习 TaskFlow、分支与动态映射,改变一项练习输入并解释任务数量或路径的变化。

用案例检查理解

以下为虚构数据与预期操作示例,用于理解流程,不代表真实业务执行结果。

查看「理解分支任务的执行路径」 ↗

常见问题

复制进去为什么提示导入错误?

Airflow 版本和 provider 包会影响示例 API,需要按环境调整。

这些任务会定时处理我的数据吗?

只有在你配置并启用的环境中才会运行,示例不自带生产数据连接。

相关文件

airflow-lab-2026.10.22-source.zip
源码包 · 2026.10.22 · 7 KB
下载 ↓
查看 SHA256 校验值cd1aa02edfee3981f7acd12c4423338a9048b8a25d7203e9011975319660d395

不包含 Airflow 密码文件、运行日志或原始配置;版本兼容性需按所用 Airflow 环境检查。

找一个工具,或一个答案

输入关键词,搜索项目、教程和案例。

项目 · 使用指南 · 案例Esc 关闭