社区
聚会
文档
使用案例
公告
博客
生态系统
浅色
深色
自动
社区
聚会
文档
使用案例
公告
博客
生态系统
内容
版本:
3.2.0
搜索文档
⌘
K
内容
概述
快速入门
安装 Airflow®
安全
教程
操作指南
UI 概览
核心概念
编写与调度
可延期的操作符与触发器
序列化
连接 & 钩子
动态任务映射
资产定义
Cron & 时间间隔
时区
资产感知调度
时间表
事件驱动调度
管理与部署
集成
Airflow 3.0+ 公共接口
最佳实践
常见问题解答
故障排除
发行政策
发行说明
隐私声明
项目
许可证
参考
算子与钩子
CLI
模板
Airflow 公共 API
配置
额外包
内部数据库详情
数据库迁移
数据库 ERD 模式
版本:
3.2.0
搜索文档
⌘
K
内容
概述
快速入门
安装 Airflow®
安全
教程
操作指南
UI 概览
核心概念
编写与调度
可延期的操作符与触发器
序列化
连接 & 钩子
动态任务映射
资产定义
Cron & 时间间隔
时区
资产感知调度
时间表
事件驱动调度
管理与部署
集成
Airflow 3.0+ 公共接口
最佳实践
常见问题解答
故障排除
发行政策
发行说明
隐私声明
项目
许可证
参考
算子与钩子
CLI
模板
Airflow 公共 API
配置
额外包
内部数据库详情
数据库迁移
数据库 ERD 模式
首页
编写与调度
编写与调度
在此您可以找到关于高级编写和调度 Airflow DAG 的详细文档。建议您先阅读
核心概念
页面。
编写
可延期的操作符与触发器
使用可延迟操作符
编写可延迟操作符
高可用性
传感器中 Mode='reschedule' 与 Deferrable=True 的区别
序列化
序列化解析顺序
Airflow 对象
连接 & 钩子
Hooks
自定义连接
动态任务映射
简单映射
使用非 TaskFlow 操作符进行映射
为非 TaskFlow 操作符分配多个参数
对任务组进行映射
过滤映射任务中的项目
转换扩展数据
合并上游数据(即 “zip”)
连接多个上游
哪些数据类型可以展开?
模板字段和映射参数如何交互?
对映射任务设置限制
自动跳过长度为零的映射
资产定义
什么是 “资产”?
什么是有效的 URI?
资产的额外信息
安全警告
创建任务以发出资产事件
依赖关系:
@asset
、
@task
与传统操作符
在单个任务中输出到多个资产
通过 AssetAlias 发出动态数据事件并创建资产
资产分区
调度
Cron & 时间间隔
Cron 预设
时区
Web UI
概念
时区感知的 DAG
资产感知调度
快速入门
使用资产调度 DAG
多个资产
从触发的资产事件中获取信息
事件驱动调度
使用条件表达式的高级资产调度
使用示例
组合资产和基于时间的调度
时间表
内置时间表
时间表比较
事件驱动调度
事件驱动调度支持的触发器
事件驱动 DAG 的用例
上一页
下一页
此条目是否有帮助?
编写与调度
建议更改此页面