node.js - 将 multipart/form-data 请求通过管道传输到另一个请求，同时更改 Node.js 中的某些字段名称

Question

我想将 multipart/form-data 中的文件上传请求流式传输到另一台服务器，并同时更改一些字段名称。

我不想将文件临时存储在磁盘上，也不想将文件完全存储在内存中。

我尝试使用 multer、busboy 和 multiparty。我认为通过使用自定义转换流我已经更接近了，但它还没有工作。

const express = require('express');
const request = require('request');
const { Transform } = require('stream');

const router = express.Router();

class TransformStream extends Transform {
  _transform(chunk, encoding, callback) {
    // here I tried to manipulate the chunk
    this.push(chunk);
    callback();
  }

  _flush(callback) {
    callback();
  }
}

router.post('/', function pipeFile(req, res) {
  const transformStream = new TransformStream();
  req.pipe(transformStream).pipe(request.post('http://somewhere.com'));
  res.sendStatus(204);
});

我尝试操作 _transform 中的 block ，但没有成功 (EPIPE)。听起来很老套，他们有更好的解决方案吗？

Answer 1

这是使用 replacestream 的解决方案以及content-disposition .

const replaceStream = require('replacestream');
const contentDisposition = require('content-disposition');

router.post('/', function pipeFile(req, res) {

  let changeFields = replaceStream(/Content-Disposition:\s+(.+)/g, (match, p1) => {
    // Parse header
    let {type, parameters} = contentDisposition.parse(p1);

    // Change the desired field
    parameters.name = "foo";

    // Prepare replacement
    let ret = `Content-Disposition: ${type}`;
    for(let key in parameters) {
      ret += `; ${key}="${parameters[key]}"`;
    }

    return ret;
  })

  req.pipe(changeFields)
  .pipe(request.post('http://somewhere.com'))
  .on('end', () => {
    res.sendStatus(204);
  });
});