• 首页
• 编写和调度

编写和调度

在这里，您可以找到关于高级编写和调度 Airflow DAG 的详细文档。建议您先查看核心概念中的页面。

编写

• 插件
  • 有什么用？
  • 为什么要基于 Airflow 构建？
  • 插件何时（重新）加载？
  • 接口
  • 示例
  • 从 CSRF 保护中排除视图
  • 作为 Python 包的插件
  • 自动重新加载 Web 服务器
  • 故障排除
• 可延期操作符 & 触发器
  • 使用可延期操作符
  • 编写可延期操作符
  • 高可用性
  • 传感器中 Mode='reschedule' 和 Deferrable=True 的区别
• DAG 文件处理
• 序列化
  • Airflow 对象
• 连接 & 钩子
  • 钩子
  • 自定义连接
• 动态任务映射
  • 简单映射
  • 使用非 TaskFlow 操作符进行映射
  • 为非 TaskFlow 操作符分配多个参数
  • 映射到任务组
  • 从映射任务中过滤项目
  • 转换扩展数据
  • 组合上游数据（又名“压缩”）
  • 连接多个上游
  • 可以扩展哪些数据类型？
  • 模板字段和映射参数如何交互？
  • 限制映射任务
  • 自动跳过零长度映射

调度

• Cron & 时间间隔
  • Cron 预设
• 时区
  • Web UI
  • 概念
  • 时区感知 DAG
• 数据感知调度
  • 快速入门
  • 什么是“数据集”？
  • 什么是有效的 URI？
  • 关于数据集的额外信息
  • 如何在 DAG 中使用数据集
  • 多个数据集
  • 将额外信息附加到发出数据集事件
  • 从先前发出的数据集事件中获取信息
  • 从触发数据集事件中获取信息
  • 通过 REST API 操作排队的数据集事件
  • 使用条件表达式的高级数据集调度
  • 使用示例
  • 通过 DatasetAlias 发出动态数据事件和创建数据集
  • 结合数据集和基于时间的调度
• 时间表
  • 内置时间表
  • 时间表比较

上一个 下一个

此条目是否对您有帮助？