• 首页
• 编写与调度

↑↓ 导航 ⏎ 选择 Esc 关闭

编写与调度

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

编写

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

调度

• Cron & 时间间隔
  • Cron 预设
• 时区
  • Web UI
  • 概念
  • 时区感知的 DAG
• 资产感知调度
  • 快速入门
  • 使用资产调度 DAG
  • 多个资产
  • 从触发的资产事件中获取信息
  • 事件驱动调度
  • 使用条件表达式的高级资产调度
  • 使用示例
  • 组合资产和基于时间的调度
• 时间表
  • 内置时间表
  • 时间表比较
• 事件驱动调度
  • 事件驱动调度支持的触发器
  • 事件驱动 DAG 的用例

上一页 下一页

此条目是否有帮助？