airflow.providers.standard.sensors.time¶

類¶

`StartTriggerArgs`	啟動觸發器執行任務所需的引數。
`TimeSensor`	等待直到一天中的指定時間。
`TimeSensorAsync`	等待直到一天中的指定時間。

模組內容¶

類 airflow.providers.standard.sensors.time.StartTriggerArgs[原始碼]¶

啟動觸發器執行任務所需的引數。

trigger_cls: str[原始碼]¶

next_method: str[原始碼]¶

trigger_kwargs: dict[str, Any] | None = None[原始碼]¶

next_kwargs: dict[str, Any] | None = None[原始碼]¶

timeout: datetime.timedelta | None = None[原始碼]¶

類 airflow.providers.standard.sensors.time.TimeSensor(*, target_time, **kwargs)[原始碼]¶

基類: airflow.sensors.base.BaseSensorOperator

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

引數:: target_time (datetime.time) – 作業在此時間後成功

另請參閱

有關如何使用此 Sensor 的更多資訊，請參閱指南: TimeSensor

target_time[原始碼]¶

poke(context)[原始碼]¶

繼承此類時請重寫此方法。

類 airflow.providers.standard.sensors.time.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 時，傳遞給觸發器的關鍵字引數。此引數在標準用法中未使用。

另請參閱

有關如何使用此 Sensor 的更多資訊，請參閱指南: TimeSensorAsync

start_trigger_args[原始碼]¶

start_from_trigger = False[原始碼]¶

end_from_trigger = False[原始碼]¶

target_time[原始碼]¶

target_datetime = None[原始碼]¶

execute(context)[原始碼]¶

建立 Operator 時請繼承此方法。

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

有關更多 Context 資訊，請參閱 get_template_context。

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

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