RXJS加密大文件并发送到亚马逊S3

const fs = require('fs');
const AWS = require('aws-sdk');
const CryptoJS = require('crypto-js');

// 配置AWS SDK
AWS.config.update({ region: 'your-region' });
const s3 = new AWS.S3();

// 读取文件
const fileContent = fs.readFileSync('path/to/large/file.txt', 'utf8');

// 加密文件内容
const encryptedContent = CryptoJS.AES.encrypt(fileContent, 'your-secret-key').toString();

// 创建一个可读流
const fileStream = fs.createReadStream('path/to/large/file.txt');

// 上传到S3
const params = {
  Bucket: 'your-bucket-name',
  Key: 'encrypted-file.txt',
  Body: encryptedContent,
  ContentType: 'text/plain'
};

s3.upload(params, (err, data) => {
  if (err) {
    console.error('Error uploading file:', err);
  } else {
    console.log('File uploaded successfully:', data.Location);
  }
});