`airflow.providers.standard.sensors.python`¶

模块内容¶

类¶

PythonSensor

等待 Python 可调用对象返回 True。

class airflow.providers.standard.sensors.python.PythonSensor(*, python_callable, op_args=None, op_kwargs=None, templates_dict=None, **kwargs)[源代码]¶

基类：airflow.sensors.base.BaseSensorOperator

等待 Python 可调用对象返回 True。

用户可以将输入参数放在 templates_dict 中，例如 templates_dict = {'start_ds': 1970}，并在可调用对象中通过调用 kwargs['templates_dict']['start_ds'] 来访问该参数

参数

python_callable (Callable) – 对可调用对象的引用
op_kwargs (collections.abc.Mapping[str, Any] | None) – 一个关键字参数字典，将在你的函数中解包
op_args (list | None) – 一个位置参数列表，在调用你的可调用对象时将被解包
templates_dict (dict | None) – 一个字典，其中的值是模板，这些模板将在 Airflow 引擎在 __init__ 和 execute 之间进行模板化，并在模板应用后在你的可调用对象的上下文中可用。

另请参阅

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

template_fields: collections.abc.Sequence[str] = ('templates_dict', 'op_args', 'op_kwargs')[源代码]¶

poke(context)[源代码]¶

在派生此类时重写。

airflow.providers.standard.sensors.python¶

模块内容¶

类¶

`airflow.providers.standard.sensors.python`¶