airflow.decorators.sensor

模块内容

类

DecoratedSensorOperator

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

函数

sensor_task([python_callable])

将函数包装到 Airflow 运算符中。
class airflow.decorators.sensor.DecoratedSensorOperator(*, task_id, **kwargs)[source]

基类: airflow.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: Sequence[str] = ('op_args', 'op_kwargs')[source]
template_fields_renderers: dict[str, str][source]
custom_operator_name = '@task.sensor'[source]
shallow_copy_attrs: Sequence[str] = ('python_callable',)[source]
airflow.decorators.sensor.sensor_task(python_callable=None, **kwargs)[source]

将函数包装到 Airflow 运算符中。

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

此条目是否有帮助？