开始使用免费开始使用

将传感器改为可延迟执行(deferrable)

您的团队在不同的流水线中运行了数十个传感器,工作器槽位正成为瓶颈。即使在 reschedule 模式下,每次传感器唤醒检查时也会短暂占用一个槽位。可延迟执行模式更进一步:它将等待完全交给 Triggerer,这是一种使用异步 I/O 的轻量级进程,从不占用工作器槽位。

您将为这个 FileSensor 配置延迟执行能力。

本练习是课程的一部分

使用 Airflow 构建数据流水线

查看课程

动手互动练习

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

开始练习