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 運算子。

接受運算子 kwargs 的 kwargs。可以在單個 DAG 中重複使用。 :param python_callable: 要裝飾的函數

此條目是否有幫助？