airflow.sensors.time_sensor

模块内容

类

TimeSensor

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

TimeSensorAsync

等待到指定的一天中的时间。
class airflow.sensors.time_sensor.TimeSensor(*, target_time, **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator

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

参数

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

另请参阅

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

poke(context)[source]

在派生此类时重写。

class airflow.sensors.time_sensor.TimeSensorAsync(*, target_time, start_from_trigger=False, trigger_kwargs=None, end_from_trigger=False, **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator

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

这将释放一个工作槽，同时它正在等待。

参数

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

  • start_from_trigger (bool) – 直接从触发器启动任务，无需进入工作进程。

  • end_from_trigger (bool) – 直接从触发器结束任务，无需进入工作进程。

  • trigger_kwargs (dict[str, Any] | None) – 当在动态任务映射期间将 start_from_trigger 设置为 True 时，传递给触发器的关键字参数。此参数在标准用法中未使用。

另请参阅

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

start_trigger_args[source]
start_from_trigger = False[source]
execute(context)[source]

在创建运算符时派生。

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

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

execute_complete(context, event=None)[source]

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

此条目是否有帮助？