airflow.providers.standard.decorators.sensor

类

DecoratedSensorOperator

包装 Python 可调用对象，并在执行时捕获 args/kwargs。

函数

sensor_task([python_callable])

将函数包装成 Airflow 运算符。

模块内容

class airflow.providers.standard.decorators.sensor.DecoratedSensorOperator(*, task_id, **kwargs)[source]

基础: airflow.providers.standard.sensors.python.PythonSensor

包装 Python 可调用对象，并在执行时捕获 args/kwargs。

参数:

  • python_callable – 对可调用对象的引用

  • task_id (str) – 任务 ID

  • op_args – 一个位置参数列表，调用可调用对象时将解包这些参数（模板化）

  • op_kwargs – 一个关键字参数字典，将在函数中解包（模板化）

  • kwargs_to_upstream – 对于某些运算符，我们可能需要将某些参数向上游传递，否则这些参数会被 DecoratedOperator 吸收（例如 PythonOperator 的 python_callable）。这使得用户可以根据需要向上游传递 kwargs。

template_fields: collections.abc.Sequence[str] = ('op_args', 'op_kwargs')[source]
template_fields_renderers: ClassVar[dict[str, str]][source]
custom_operator_name = '@task.sensor'[source]
shallow_copy_attrs: collections.abc.Sequence[str] = ('python_callable',)[source]
airflow.providers.standard.decorators.sensor.sensor_task(python_callable=None, **kwargs)[source]

将函数包装成 Airflow 运算符。

接受运算符 kwarg 的 kwargs。可在单个 DAG 中重用。:param python_callable: 要装饰的函数

这篇文章有帮助吗？