`airflow.providers.standard.sensors.time_delta`¶

模組內容¶

類別¶

`TimeDeltaSensor`	等待一段時間間隔後，在資料間隔之後執行。
`TimeDeltaSensorAsync`	TimeDeltaSensor 的可延遲替代方案。
`WaitSensor`	一個感測器，會等待指定的時間段才完成。

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

基底類別： airflow.sensors.base.BaseSensorOperator

等待一段時間間隔後，在資料間隔之後執行。

參數: delta – 在資料間隔後等待成功的時間長度。

另請參閱

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

poke(context)[原始碼]¶

衍生此類別時覆寫。

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

基底類別： TimeDeltaSensor

TimeDeltaSensor 的可延遲替代方案。

將自身延遲以避免在等待時佔用 worker 插槽。

參數

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

另請參閱

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

execute(context)[原始碼]¶

在建立運算子時衍生。

Context 是與渲染 jinja 模板時使用的相同字典。

請參閱 get_template_context 以取得更多上下文。

execute_complete(context, event=None)[原始碼]¶

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

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

基底類別： airflow.sensors.base.BaseSensorOperator

一個感測器，會等待指定的時間段才完成。

這與 TimeDeltaSensor 的不同之處在於，等待時間是從任務開始時計算，而不是 DAG 運行的 data_interval_end。