FTPFileTransmitOperator¶

使用 FTPFileTransmitOperator 从/向 FTP 服务器传输（获取或放置）文件。

使用操作符¶

参数定义请参考 FTPFileTransmitOperator。

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

tests/system/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/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 服务器传输（获取或放置）文件。

使用操作符¶

参数定义请参考 FTPSFileTransmitOperator。

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

tests/system/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/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,
)