何时使用 poke、reschedule 或 deferrable
您的团队正在审查三个流水线中的传感器配置:
- Pipeline A: 一个传感器会检查文件是否存在,通常在 Dag 启动后 10 秒内到达。
- Pipeline B: 一个传感器等待合作方的数据馈送,通常在 4 小时窗口内的某个时间点到达。会有 20 个类似的传感器并发运行。
- Pipeline C: 一个传感器每 2 分钟检查一次 API 端点,通常需要等待 15 分钟。
哪种传感器模式组合最合适?
本练习是课程的一部分
您的团队正在审查三个流水线中的传感器配置:
哪种传感器模式组合最合适?
本练习是课程的一部分