airflow.providers.sftp.sensors.sftp¶

此模块包含 SFTP 传感器。

类¶

SFTPSensor

等待 SFTP 上存在文件或目录。

模块内容¶

class airflow.providers.sftp.sensors.sftp.SFTPSensor(*, path, file_pattern='', newer_than=None, sftp_conn_id='sftp_default', python_callable=None, op_args=None, op_kwargs=None, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶

继承自: airflow.sensors.base.BaseSensorOperator

等待 SFTP 上存在文件或目录。

参数:

path (str) – 远程文件或目录路径
file_pattern (str) – 用于匹配文件的模式 (fnmatch 格式)
sftp_conn_id (str) – 传感器运行所使用的连接
newer_than (datetime.datetime | str | None) – 文件或文件路径必须晚于此 DateTime，比较是包含性的
deferrable (bool) – 如果等待完成，是否延迟任务直到完成，默认为 False。