Airflow Summit 2025 即将于 10 月 07-09 日举行。立即注册,获取早鸟票!

传感器

传感器是一种特殊类型的 Operator,它们被设计用来做一件事——等待某个事件发生。可以是基于时间的等待,也可以是等待文件出现或外部事件发生,但它们所做的就是一直等待直到某件事发生,然后成功,以便其下游任务可以运行。

由于它们主要处于空闲状态,传感器有两种不同的运行模式,以便您更有效地使用它们

  • poke(默认):传感器在其整个运行期间占用一个 Worker 插槽

  • reschedule:传感器仅在检查时占用 Worker 插槽,并在两次检查之间休眠设定的时长

pokereschedule 模式可以在实例化传感器时直接配置;通常,它们之间的权衡在于延迟。每秒检查一次的传感器应处于 poke 模式,而每分钟检查一次的传感器应处于 reschedule 模式。

与 Operators 非常相似,Airflow 提供了大量内置传感器供您使用,包括核心 Airflow 和通过我们的 Providers 系统提供的传感器。

此条目是否有帮助?