• 主页
• 编写与调度

编写与调度

您可以在此处找到有关 Airflow DAG 高级编写和调度的详细文档。建议您先查阅核心概念中的页面。

编写

• 可延迟操作符与触发器
  • 使用可延迟操作符
  • 编写可延迟操作符
  • 高可用性
  • 传感器中 Mode=’reschedule’ 和 Deferrable=True 的区别
• 序列化
  • Airflow 对象
• 连接与钩子
  • 钩子
  • 自定义连接
• 动态任务映射
  • 简单映射
  • 使用非 TaskFlow 操作符进行映射
  • 为非 TaskFlow 操作符分配多个参数
  • 映射任务组
  • 从映射任务中过滤条目
  • 转换扩展数据
  • 组合上游数据（即“zip”）
  • 串联多个上游
  • 哪些数据类型可以扩展？
  • 模板化字段和映射参数如何交互？
  • 对映射任务施加限制
  • 自动跳过长度为零的映射
• 资产定义
  • 什么是“资产”？
  • 什么是有效 URI？
  • 关于资产的额外信息
  • 创建任务以发出资产事件
  • @asset、@task 和经典操作符之间的依赖关系
  • 在一个任务中输出到多个资产
  • 通过 AssetAlias 发出动态数据事件和创建资产

调度

• Cron 与时间间隔
  • Cron 预设
• 时区
  • Web UI
  • 概念
  • 时区感知的 DAGs
• 资产感知调度
  • 快速入门
  • 使用资产调度 DAGs
  • 多个资产
  • 从触发资产事件中获取信息
  • 通过 REST API 操作队列中的资产事件
  • 使用条件表达式进行高级资产调度
  • 使用示例
  • 组合资产和基于时间的调度
• 时间表
  • 内建时间表
  • 时间表比较
• 事件驱动调度
  • 事件驱动调度的支持触发器
  • 事件驱动 DAGs 的用例

上一页 下一页

本条目是否有帮助？