airflow.providers.standard.sensors.time

模块内容

类

StartTriggerArgs

从触发器启动任务执行所需的参数。

TimeSensor

等待到一天中的指定时间。

TimeSensorAsync

等待到一天中的指定时间。
class airflow.providers.standard.sensors.time.StartTriggerArgs[源代码]

从触发器启动任务执行所需的参数。

trigger_cls: str[源代码]
next_method: str[源代码]
trigger_kwargs: dict[str, Any] | None[源代码]
next_kwargs: dict[str, Any] | None[源代码]
timeout: datetime.timedelta | None[源代码]
class airflow.providers.standard.sensors.time.TimeSensor(*, target_time, **kwargs)[源代码]

基类: airflow.sensors.base.BaseSensorOperator

等待到一天中的指定时间。

参数

target_time (datetime.time) – 作业成功的时间

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：TimeSensor

poke(context)[源代码]

在派生此类时重写。

class 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 时，在动态任务映射期间传递给触发器的关键字参数。此参数在标准用法中不使用。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：TimeSensorAsync

start_trigger_args[源代码]
start_from_trigger = False[源代码]
execute(context)[源代码]

创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

execute_complete(context, event=None)[源代码]

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

此条目是否有帮助？