javascript - Node.js ストリーム :- ストリーム関数が同じファイルに対して 2 回目の呼び出しを行わない

Question

SFTB、POSTサーバーに でリクエストが来ましたmultipart/form-data。そのリクエストから、ファイルの内容を取得したいと思います。

私は提供されたファイルstreamsとパイプを読んでいます。これは、 [私がそのために使用している]を使用してリソースをフェッチするカスタム関数にコンテンツを渡していることcvsParserの単なるインスタンスであり、それをフェッチした後、画像を圧縮しています.csv-streamifyTransformhttpgot

今問題は、初めてファイルを送信するとチャームのように機能しますが、同じファイルを2回目に送信しようとすると、部分全体がスキップされ、イベントハンドラーstreamに直接ジャンプします。finish

初めてのログ:-

Submitting
Converting image at C:\image-minifier-sqd\build\src\1469004088476.bell.svg
Build is present at build\dest\1469004088476.bell.svg
Converting image at C:\image-minifier-sqd\build\src\1469004088996.mail.svg
Build is present at build\dest\1469004088996.mail.svg
Finished

同じファイルを 2 回目に送信したときのログ [フロントエンドでの更新の有無にかかわらず]

Submitting
Finished

参考までに、フロントエンドではfetchAPI を使用してPOSTリクエストを行っています。

私のサーバーコード:-

function createParser() {
  var parser = new Transform({objectMode: true});
  parser._transform = function(data, encoding, done) {
    const date = new Date();
    const link = data.toString().slice(2,-3);
    const fileName = date.getTime()+ '.' +link.split( '/' ).pop(),
          filePath = path.resolve(__dirname,`build/src/${fileName}`);
    got.stream(link)
    .pipe(fs.createWriteStream(filePath,{flags:'a'}))
    .on('close',_ => {
      console.log(`Converting image at ${filePath}`)
      //Compressing images
      imagemin([filePath],'build/dest',{
        plugins: [
          imageminMozjpeg(),
          imageminPngquant({speed: 10}),
          imageminSvgo(),
          imageminGifsicle()
        ]
      })
      .then(file => {
        console.log(`Build is present at ${file[0].path}`);
        this.push(file[0].path);
        done(); 
      }); 
    });  
  };

  return parser;
}
//A request comes here with multipart/form-data
app.post('/submit/csv',upload.array('data'),(req, res) => {
  console.log('Submitting')
  const stream = fs.createReadStream(path.resolve(__dirname,req.files[0].path))
                  .pipe(csvParser)
                  .pipe(createParser())
                  .pipe(res)
                  .on('finish',_ => {
                    log('Finished');
                    res.end();
                  });

});

ありがとう。