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,
)