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)[源代码]¶

处理触发器触发时的事件并立即返回。