感測器¶
感測器是一種特殊型別的 Operator,它們被設計用來做一件事——等待某個事件發生。可以是基於時間的等待,也可以是等待檔案出現或外部事件發生,但它們所做的就是一直等待直到某件事發生,然後成功,以便其下游任務可以執行。
由於它們主要處於空閒狀態,感測器有兩種不同的執行模式,以便您更有效地使用它們
poke(預設):感測器在其整個執行期間佔用一個 Worker 插槽reschedule:感測器僅在檢查時佔用 Worker 插槽,並在兩次檢查之間休眠設定的時長
poke 和 reschedule 模式可以在例項化感測器時直接配置;通常,它們之間的權衡在於延遲。每秒檢查一次的感測器應處於 poke 模式,而每分鐘檢查一次的感測器應處於 reschedule 模式。
與 Operators 非常相似,Airflow 提供了大量內建感測器供您使用,包括核心 Airflow 和透過我們的 Providers 系統提供的感測器。