airflow.providers.sftp.decorators.sensors.sftp¶

函数¶

sftp_sensor_task([python_callable])

将一个函数包装成一个 Airflow 运算符。

airflow.providers.sftp.decorators.sensors.sftp.sftp_sensor_task(python_callable=None, **kwargs)[source]¶

将一个函数包装成一个 Airflow 运算符。

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