以.zip格式发送S3文件作为Express.js中的响应

npm install express aws-sdk

const AWS = require('aws-sdk');
AWS.config.update({
  accessKeyId: 'your-access-key',
  secretAccessKey: 'your-secret-access-key',
  region: 'your-region'
});

const fs = require('fs');
const archiver = require('archiver');
const s3 = new AWS.S3();

function zipAndSendS3File(fileName, res) {
  const downloadParams = {
    Bucket: 'your-bucket-name',
    Key: fileName
  };

  const fileStream = fs.createWriteStream(fileName);
  const archive = archiver('zip', {
    zlib: { level: 9 } // 设置压缩级别为最高
  });

  // 将压缩的数据流写入文件流
  archive.pipe(fileStream);

  // 下载S3文件并添加到压缩包
  s3.getObject(downloadParams, (error, data) => {
    if (error) {
      console.error('Failed to download file from S3:', error);
      res.status(500).send('Failed to download file from S3');
    } else {
      archive.append(data.Body, { name: fileName });
      archive.finalize();

      // 监听压缩完成事件，将压缩包发送给客户端
      fileStream.on('close', () => {
        res.download(fileName, `${fileName}.zip`, (error) => {
          if (error) {
            console.error('Failed to send zip file:', error);
            res.status(500).send('Failed to send zip file');
          }

          // 删除临时文件
          fs.unlinkSync(fileName);
        });
      });
    }
  });
}

app.get('/download', (req, res) => {
  const fileName = 'your-file-name.ext'; // 替换为你要下载的S3文件名
  zipAndSendS3File(fileName, res);
});