Skip to content

11. 延伸阅读与总结

一句话理解:Airflow 不是孤立工具,它与 Kubeflow、MLflow、KServe、dbt、Spark、Kubernetes 等共同构成 AI 平台与数据工程工具链;学完本章后,建议沿着“单机使用 → 生产部署 → 生态集成”的路线继续深入。

11.1 核心官方资源

资源说明
Apache Airflow 官方文档最权威、最及时的参考
Apache Airflow GitHub源码、issue、release note
Airflow Quickstart本地快速上手
Airflow Providers官方 provider 包文档
Astronomer 文档商业化托管与最佳实践

11.2 关键概念文档

资源说明
DAGsDAG 定义、调度、依赖、Task Group
OperatorsOperator 概念与自定义
TasksTask 与 TaskInstance
DAG RunsDAG Run 与 execution date
Executors各种 Executor 对比
XComs任务间数据交换
SchedulerScheduler 工作原理与调优
DAG File ProcessingDAG Processor 解析流程
DAG SerializationDAG 序列化机制
Deferrable OperatorsDefer 与 Triggerer
Datasets数据驱动调度
Database SetupMetadata DB 配置

11.3 相邻主题交叉引用

主题关系链接
KubeflowML 工作流编排,可与 Airflow 互补或替代Kubeflow 总览
MLflowAirflow 编排训练,MLflow 记录实验/注册模型MLflow 总览
KubeRayRay 作业可作为 Airflow 任务执行KubeRay 总览
KServeAirflow 编排模型部署,KServe 负责服务KServe 总览
KubernetesKubernetesExecutor / Celery on K8s 底座Kubernetes 总览
Operator 模式Airflow 自身也依赖 K8s Operator 部署Operator 模式总览
AI SREAirflow 生产监控、告警、SLOAI SRE 总览

11.4 进阶论文、博客与演讲

类型资源看点
论文Airbnb 博客 — Airflow 起源Airflow 最初设计动机
实践Astronomer — Airflow Best Practices企业级最佳实践
对比Prefect vs Airflow现代编排工具对比
对比Dagster vs Airflow数据资产视角对比
工程Spotify 数据平台实践大规模 Airflow 使用经验
工程Netflix 数据流水线高可用编排实践

11.5 推荐学习路径

  1. 第 1 周:精读本主题 01-05 章,运行 Mini Demo。
  2. 第 2 周:读 06 源码分析 + 07-09 生产与最佳实践;尝试用 LocalExecutor + PostgreSQL 本地部署 Airflow。
  3. 第 3 周:写一个自己的 DAG,接入 MLflow/KServe 或 dbt/Spark;尝试 KubernetesExecutor。
  4. 第 4 周:读官方 release note,关注 Airflow 3 的 Execution API、JWT、Asset 演进。

11.6 一句话总结

Airflow 是数据与 ML 流水线的“调度指挥中心”:

  • DAG 用 Python 描述任务依赖;
  • Scheduler 决定何时运行;
  • Executor 决定在哪运行;
  • Metadata Database 记录所有状态;
  • XCom 传递任务数据;
  • Triggerer 让异步等待不浪费资源。

它与 Kubeflow、MLflow、KServe、Kubernetes 等工具组合,构成从数据摄取到模型部署的完整 AI 基础设施链路。

本章小结

  • 官方文档和 GitHub 是最权威的学习来源。
  • Airflow 与 Kubeflow、MLflow、KServe、Kubernetes、AI SRE 等主题紧密相连。
  • 学习路径遵循:本地 Demo → 自定义 DAG → 生产部署 → 生态集成 → 关注 Airflow 3 演进。

参考来源

Released under CC-BY-SA-4.0 License.