airflow.sensors.time_delta

模組內容

類別

TimeDeltaSensor

等待資料區間後的時間差。

TimeDeltaSensorAsync

TimeDeltaSensor 的可延遲替代方案。
class airflow.sensors.time_delta.TimeDeltaSensor(*, delta, **kwargs)[source]

基於: airflow.sensors.base.BaseSensorOperator

等待資料區間後的時間差。

參數

delta – 成功前，資料區間後等待的時間長度。

參見

關於如何使用此感測器的更多資訊，請查看指南： TimeDeltaSensor

poke(context)[source]

衍生此類別時覆寫。

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

基於: TimeDeltaSensor

TimeDeltaSensor 的可延遲替代方案。

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

參數

  • delta – 成功前，資料區間後等待的時間長度。

  • end_from_trigger (bool) – 直接從觸發器結束任務，而無需進入 worker。

參見

關於如何使用此感測器的更多資訊，請查看指南： TimeDeltaSensorAsync

execute(context)[source]

在建立 operator 時衍生。

Context 是與渲染 jinja 範本時使用的字典相同。

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

execute_complete(context, event=None)[source]

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

此條目是否有幫助？