Sensors

Sensors 是一種特殊的 Operator,其設計目的只做一件事 - 等待某事發生。它可以是基於時間的,或是等待檔案,或是外部事件,但它們所做的只是等待直到某事發生,然後成功,以便其下游任務可以運行。

因為它們主要處於閒置狀態,Sensors 有兩種不同的運行模式,因此您可以更有效率地使用它們。

  • poke(預設):Sensor 在其整個運行時段都佔用一個 worker slot。

  • reschedule:Sensor 僅在檢查時佔用 worker slot,並在檢查之間休眠一段設定的時間。

pokereschedule 模式可以在您實例化 sensor 時直接配置;通常,它們之間的權衡是延遲。每秒檢查一次的項目應處於 poke 模式,而每分鐘檢查一次的項目應處於 reschedule 模式。

就像 Operators 一樣,Airflow 有大量的預建 Sensors 可供您使用,無論是在核心 Airflow 中還是透過我們的 providers 系統。

這個條目有幫助嗎?