使用python或node.js将平面文件从SFTP上传到S3

pip install paramiko boto3

npm install ssh2 aws-sdk

import paramiko
import boto3

const fs = require('fs');
const { Client } = require('ssh2');
const AWS = require('aws-sdk');

# SFTP连接参数
sftp_host = 'sftp.example.com'
sftp_port = 22
sftp_username = 'username'
sftp_password = 'password'

# SFTP下载文件路径和本地保存路径
sftp_remote_path = '/path/to/remote/file.txt'
local_path = '/path/to/local/file.txt'

# 创建SFTP连接
transport = paramiko.Transport((sftp_host, sftp_port))
transport.connect(username=sftp_username, password=sftp_password)
sftp = transport.open_sftp()

# 下载文件
sftp.get(sftp_remote_path, local_path)

# 关闭连接
sftp.close()
transport.close()

// SFTP连接参数
const sftpConfig = {
  host: 'sftp.example.com',
  port: 22,
  username: 'username',
  password: 'password'
};

// SFTP下载文件路径和本地保存路径
const sftpRemotePath = '/path/to/remote/file.txt';
const localPath = '/path/to/local/file.txt';

// 创建SFTP连接并下载文件
const conn = new Client();
conn.on('ready', () => {
  conn.sftp((err, sftp) => {
    if (err) throw err;
    sftp.fastGet(sftpRemotePath, localPath, (err) => {
      if (err) throw err;
      conn.end();
    });
  });
}).connect(sftpConfig);

# S3连接参数
s3_access_key = 'your_access_key'
s3_secret_key = 'your_secret_key'
s3_bucket_name = 'your_bucket_name'
s3_object_key = 'path/to/s3/file.txt'

# 创建S3连接
s3 = boto3.client('s3', aws_access_key_id=s3_access_key, aws_secret_access_key=s3_secret_key)

# 上传文件
s3.upload_file(local_path, s3_bucket_name, s3_object_key)

// S3连接参数
const s3AccessKeyId = 'your_access_key';
const s3SecretAccessKey = 'your_secret_key';
const s3BucketName = 'your_bucket_name';
const s3ObjectKey = 'path/to/s3/file.txt';

// 配置S3连接
AWS.config.update({
  accessKeyId: s3AccessKeyId,
  secretAccessKey: s3SecretAccessKey
});

// 创建S3连接
const s3 = new AWS.S3();

// 上传文件
const fileContent = fs.readFileSync(localPath);
const params = {
  Bucket: s3BucketName,
  Key: s3ObjectKey,
  Body: fileContent
};
s3.upload(params, (err, data) => {
  if (err) throw err;
  console.log('File uploaded successfully');
});