FTPFileTransmitOperator¶

使用 FTPFileTransmitOperator 从 FTP 服务器获取文件或将文件放到 FTP 服务器。

使用操作符¶

有关参数定义，请查看 FTPFileTransmitOperator。

以下示例显示了如何使用 FTPFileTransmitOperator 将本地存储的文件传输到远程 FTP 服务器

tests/system/providers/ftp/example_ftp.py[源代码]

ftp_put = FTPFileTransmitOperator(
    task_id="test_ftp_put",
    ftp_conn_id="ftp_default",
    local_filepath="/tmp/filepath",
    remote_filepath="/remote_tmp/filepath",
    operation=FTPOperation.PUT,
    create_intermediate_dirs=True,
)

以下示例显示了如何使用 FTPFileTransmitOperator 从远程 FTP 服务器拉取文件。

tests/system/providers/ftp/example_ftp.py[源代码]

ftp_get = FTPFileTransmitOperator(
    task_id="test_ftp_get",
    ftp_conn_id="ftp_default",
    local_filepath="/tmp/filepath",
    remote_filepath="/remote_tmp/filepath",
    operation=FTPOperation.GET,
    create_intermediate_dirs=True,
)

FTPSFileTransmitOperator¶

使用 FTPSFileTransmitOperator 从 FTPS 服务器获取文件或将文件放到 FTPS 服务器。

使用操作符¶

有关参数定义，请查看 FTPSFileTransmitOperator。

以下示例显示了如何使用 FTPSFileTransmitOperator 将本地存储的文件传输到远程 FTPS 服务器

tests/system/providers/ftp/example_ftp.py[源代码]

ftps_put = FTPSFileTransmitOperator(
    task_id="test_ftps_put",
    ftp_conn_id="ftps_default",
    local_filepath="/tmp/filepath",
    remote_filepath="/remote_tmp/filepath",
    operation=FTPOperation.PUT,
    create_intermediate_dirs=True,
)

以下示例显示了如何使用 FTPSFileTransmitOperator 从远程 FTPS 服务器拉取文件。

tests/system/providers/ftp/example_ftp.py[源代码]

ftps_get = FTPSFileTransmitOperator(
    task_id="test_ftps_get",
    ftp_conn_id="ftps_default",
    local_filepath="/tmp/filepath",
    remote_filepath="/remote_tmp/filepath",
    operation=FTPOperation.GET,
    create_intermediate_dirs=True,
)