Node.js：构造multipart请求调用图片上传至S3的后端接口

首先得指出你原来代码的核心问题：你直接把图片的下载流传给uploadImageFile，但这个流是原始的图片二进制数据，并不是multipart/form-data格式的请求。而你的uploadImageFile依赖multiparty去解析multipart请求里的文件part，所以自然无法触发后续的S3上传逻辑。

另外，你的原uploadImageFile代码还有个小bug：form.on('part')的事件监听写在了var form = new multiparty.Form()之前，这会导致监听无效，因为form对象还没创建，得先创建form再绑定事件。

下面是修正后的完整实现：

第一步：修正你的后端上传函数 #

先把原函数的事件顺序调整正确，同时补充完整S3上传的核心逻辑：

const request = require('request');
const multiparty = require('multiparty');
const express = require('express');
const AWS = require('aws-sdk'); // 引入AWS SDK用于S3上传

const profile = express.Router();
profile.route('/').post(uploadImageFile);

// 修正后的uploadImageFile
function uploadImageFile(req, res, next) {
  // 先创建form对象
  const form = new multiparty.Form();
  
  // 错误处理
  form.on('error', function(err){
    next(err);
  });
  
  // 监听文件part
  form.on('part', function(part) {
    if (!part.filename) {
      // 忽略非文件类型的表单字段
      part.resume();
      return;
    }
    
    const filename = part.filename;
    console.log(`开始上传文件：${filename}`);
    
    // 初始化S3客户端（替换成你的AWS配置）
    const s3 = new AWS.S3({
      accessKeyId: '你的AWS Access Key',
      secretAccessKey: '你的AWS Secret Key'
    });
    
    // 直接用part流上传到S3，无需本地存储
    s3.upload({
      Bucket: '你的S3存储桶名称',
      Key: filename,
      Body: part
    }, (err, data) => {
      if (err) {
        part.resume(); // 出现错误也要释放流，避免内存泄漏
        return next(err);
      }
      res.json({ 
        success: true, 
        message: '文件上传完成',
        s3Url: data.Location 
      });
    });
  });
  
  // 开始解析请求
  form.parse(req);
}

// 启动Express服务（如果尚未启动）
const app = express();
app.use('/profile', profile);
app.listen(3000, () => console.log('服务运行在3000端口'));

第二步：构造正确的Multipart请求调用接口 #

现在我们用request模块构造标准的multipart/form-data请求，把从URL下载的图片作为表单文件字段发送给接口：

const request = require('request');

function downloadAndUploadToS3(imageUrl, callback) {
  // 构造multipart表单数据，将图片URL的流作为文件字段
  const formData = {
    // 字段名可根据需求调整，后端会通过part.filename获取文件名
    image: request(imageUrl)
  };
  
  // 向后端接口发起POST请求
  request.post({
    url: 'http://localhost:3000/profile', // 对应你的路由地址
    formData: formData
  }, function(err, res, body) {
    if (err) {
      return callback(err);
    }
    // 解析后端返回的JSON结果
    try {
      const result = JSON.parse(body);
      callback(null, result);
    } catch (parseErr) {
      callback(parseErr);
    }
  });
}

// 调用示例
downloadAndUploadToS3("https://lh4.googleusercontent.com/photo.jpg", (err, result) => {
  if (err) {
    console.error('上传失败:', err);
    return;
  }
  console.log('上传成功:', result);
});

关键说明 #

1. 为什么这样能行？：request的formData选项会自动帮我们把内容包装成multipart/form-data格式，包括正确的边界符、Content-Disposition头信息，这样multiparty就能正确解析出文件part，触发你的S3上传逻辑。
2. 内存优化：直接把图片的下载流作为表单的文件内容，不需要先把整个图片下载到本地再上传，节省内存开销。
3. 错误处理：补充了S3上传的错误处理，以及非文件字段的忽略逻辑，避免内存泄漏。

内容的提问来源于stack exchange，提问作者Leah Wolff