`airflow.providers.standard.sensors.time_delta`¶

模块内容¶

类¶

`TimeDeltaSensor`	等待运行的数据间隔之后的时间间隔。
`TimeDeltaSensorAsync`	TimeDeltaSensor 的可延迟的替代方案。
`WaitSensor`	在完成之前等待指定时间段的传感器。

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

基类： airflow.sensors.base.BaseSensorOperator

等待运行的数据间隔之后的时间间隔。

参数: delta – 数据间隔后等待成功的时间长度。

另请参阅

有关如何使用此传感器的更多信息，请查看指南：TimeDeltaSensor

poke(context)[源代码]¶

在派生此类时重写。

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

基类： TimeDeltaSensor

TimeDeltaSensor 的可延迟的替代方案。

将自己延迟以避免在等待时占用 worker 槽位。

参数

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

另请参阅

有关如何使用此传感器的更多信息，请查看指南：TimeDeltaSensorAsync

execute(context)[源代码]¶

在创建操作符时派生。

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

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

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

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

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

基类： airflow.sensors.base.BaseSensorOperator

在完成之前等待指定时间段的传感器。

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