airflow.sensors.time_sensor

模組內容

類別

TimeSensor (時間感測器)

等待直到一天中的指定時間。

TimeSensorAsync (非同步時間感測器)

等待直到一天中的指定時間。
class airflow.sensors.time_sensor.TimeSensor(*, target_time, **kwargs)[原始碼]

繼承自: airflow.sensors.base.BaseSensorOperator

等待直到一天中的指定時間。

參數

target_time (datetime.time) – 作業成功的目標時間

參見

有關如何使用此感測器的更多資訊，請查看指南：TimeSensor (時間感測器)

poke(context)[原始碼]

衍生此類別時覆寫。

class airflow.sensors.time_sensor.TimeSensorAsync(*, target_time, start_from_trigger=False, trigger_kwargs=None, end_from_trigger=False, **kwargs)[原始碼]

繼承自: airflow.sensors.base.BaseSensorOperator

等待直到一天中的指定時間。

這會在等待時釋放 worker 插槽。

參數

  • target_time (datetime.time) – 作業成功的目標時間

  • start_from_trigger (bool) – 直接從觸發器啟動任務，無需進入 worker。

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

  • trigger_kwargs (dict[str, Any] | None) – 當 start_from_trigger 設定為 True 時，在動態任務映射期間傳遞給觸發器的關鍵字參數。此參數在標準用法中未使用。

參見

有關如何使用此感測器的更多資訊，請查看指南：TimeSensorAsync (非同步時間感測器)

start_trigger_args[原始碼]
start_from_trigger = False[原始碼]
execute(context)[原始碼]

在建立操作器時衍生。

Context (上下文) 與呈現 Jinja 範本時使用的字典相同。

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

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

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

此條目是否有幫助？