airflow.providers.standard.sensors.time_delta¶

類¶

`TimeDeltaSensor`	等待一個時間差。
`TimeDeltaSensorAsync`	TimeDeltaSensor 的可延遲直接替代。
`WaitSensor`	一個感測器，它在完成前等待指定的時長。

模組內容¶

class airflow.providers.standard.sensors.time_delta.TimeDeltaSensor(*, delta, **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

等待一個時間差。

如果 DAG 執行存在 data_interval_end，則將根據它評估 delta，否則將使用 run_after。

引數:: delta – 成功前等待的時長。

另請參閱

有關如何使用此感測器的更多資訊，請參閱指南: TimeDeltaSensor

delta[source]¶

poke(context)[source]¶

派生此類時重寫。

class airflow.providers.standard.sensors.time_delta.TimeDeltaSensorAsync(*, end_from_trigger=False, delta, **kwargs)[source]¶

基類: TimeDeltaSensor

TimeDeltaSensor 的可延遲直接替代。

它會自行延遲，以避免在等待時佔用工作節點槽位。

引數:

delta – 資料間隔後等待成功的時間長度。
end_from_trigger (bool) – 直接從觸發器結束任務，無需進入工作節點。

另請參閱

有關如何使用此感測器的更多資訊，請參閱指南: TimeDeltaSensorAsync

end_from_trigger = False[source]¶

execute(context)[source]¶

建立運算子時派生。

執行任務的主要方法。Context 是渲染 Jinja 模板時使用的相同字典。

有關更多上下文，請參閱 get_template_context。

execute_complete(context, event=None)[source]¶

處理觸發器觸發時的事件並立即返回。

class airflow.providers.standard.sensors.time_delta.WaitSensor(time_to_wait, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

一個感測器，它在完成前等待指定的時長。

這與 TimeDeltaSensor 不同，因為等待時間是從任務開始時測量的，而不是從 DAG 執行的 data_interval_end 測量。