airflow.providers.ftp.sensors.ftp

类

FTPSensor

等待文件或目录出现在 FTP 上。

FTPSSensor

等待文件或目录出现在基于 SSL 的 FTP 上。

模块内容

class airflow.providers.ftp.sensors.ftp.FTPSensor(*, path, ftp_conn_id='ftp_default', fail_on_transient_errors=True, **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator

等待文件或目录出现在 FTP 上。

参数:

  • path (str) – 远程文件或目录路径

  • fail_on_transient_errors (bool) – 在所有错误（包括 4xx 瞬时错误）时失败。默认值为 True。

  • ftp_conn_id (str) – 用于运行传感器的 ftp 连接 ID 引用。

template_fields: collections.abc.Sequence[str] = ('path',)[source]

瞬时错误，可以重试操作

transient_errors = [421, 425, 426, 434, 450, 451, 452][source]
error_code_pattern[source]
path[source]
ftp_conn_id = 'ftp_default'[source]
fail_on_transient_errors = True[source]
poke(context)[source]

派生此类时覆盖此方法。

class airflow.providers.ftp.sensors.ftp.FTPSSensor(*, path, ftp_conn_id='ftp_default', fail_on_transient_errors=True, **kwargs)[source]

基类: FTPSensor

等待文件或目录出现在基于 SSL 的 FTP 上。

此条目有帮助吗？