SFTP 到 Amazon S3¶

使用 SFTPToS3Operator 传输操作符将数据从 SFTP 服务器复制到 Amazon Simple Storage Service (S3) 文件。

先决条件任务¶

要使用这些操作符，您必须完成以下几项操作

使用 AWS 控制台或 AWS CLI 创建必要的资源。
通过 pip 安装 API 库。
pip install 'apache-airflow[amazon]'
详细信息请参见 Airflow® 的安装
设置连接.

此操作符将数据从 SFTP 服务器加载到 Amazon S3 文件。

要获取有关此操作符的更多信息，请访问：SFTPToS3Operator

用法示例

tests/system/amazon/aws/example_sftp_to_s3.py

sftp_to_s3_job = SFTPToS3Operator(
    task_id="sftp_to_s3_job",
    sftp_path="/tmp/sftp_path",
    s3_bucket=s3_bucket,
    s3_key=s3_key,
)