开始使用免费开始使用

何时使用 poke、reschedule 或 deferrable

您的团队正在审查三个流水线中的传感器配置:

  • Pipeline A: 一个传感器会检查文件是否存在,通常在 Dag 启动后 10 秒内到达。
  • Pipeline B: 一个传感器等待合作方的数据馈送,通常在 4 小时窗口内的某个时间点到达。会有 20 个类似的传感器并发运行。
  • Pipeline C: 一个传感器每 2 分钟检查一次 API 端点,通常需要等待 15 分钟。

哪种传感器模式组合最合适?

本练习是课程的一部分

使用 Airflow 构建数据流水线

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习