airflow.providers.standard.sensors.time_delta¶

类¶

`TimeDeltaSensor`	等待一个时间差。
`TimeDeltaSensorAsync`	TimeDeltaSensor 的可延迟直接替代。
`WaitSensor`	一个传感器，它在完成前等待指定的时长。

模块内容¶

class airflow.providers.standard.sensors.time_delta.TimeDeltaSensor(*, delta, **kwargs)[source]¶

基类: airflow.sensors.base.BaseSensorOperator

等待一个时间差。

如果 DAG 运行存在 data_interval_end，则将根据它评估 delta，否则将使用 run_after。

参数:: delta – 成功前等待的时长。

另请参阅

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

delta[source]¶

poke(context)[source]¶

派生此类时重写。

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

基类: TimeDeltaSensor

TimeDeltaSensor 的可延迟直接替代。

它会自行延迟，以避免在等待时占用工作节点槽位。

参数:

delta – 数据间隔后等待成功的时间长度。
end_from_trigger (bool) – 直接从触发器结束任务，无需进入工作节点。

另请参阅

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

end_from_trigger = False[source]¶

execute(context)[source]¶

创建操作符时派生。

执行任务的主要方法。Context 是渲染 Jinja 模板时使用的相同字典。

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

execute_complete(context, event=None)[source]¶

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

class airflow.providers.standard.sensors.time_delta.WaitSensor(time_to_wait, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶

基类: airflow.sensors.base.BaseSensorOperator

一个传感器，它在完成前等待指定的时长。

这与 TimeDeltaSensor 不同，因为等待时间是从任务开始时测量的，而不是从 DAG 运行的 data_interval_end 测量。