Node.js Transform流flush函数失效，无法输出单个利润总和

你的代码存在三个关键问题，导致无法正确输出最终的利润总和：

1. Flush函数语法错误：Transform流的配置中，你错误地将flush函数写为function(done)，正确写法是通过flush属性指定对应的回调函数。
2. 全局累加变量风险：TOTAL定义在函数外部，属于全局变量，多次调用sumProfit()会保留之前的累加值，导致结果错误。
3. 多余的JSON解析：csvtojson在objectMode下已经把CSV行转换成了JS对象，不需要再用JSON.parse(chunk)解析。

修正后的sumProfit代码 #

const { Transform } = require("stream");
const { EOL } = require("os");

const sumProfit = () => {
  // 将累加变量放在函数内部，每次调用都初始化新值
  let total = 0;

  return new Transform({
    objectMode: true,
    transform: (chunk, encoding, done) => {
      // 直接使用csvtojson输出的对象，无需JSON解析
      total += Math.floor(parseFloat(chunk.profit));
      done(null);
    },
    // 正确配置flush函数，流结束时输出最终总和
    flush(done) {
      done(null, String(total) + EOL);
    },
  });
};

module.exports = { sumProfit };

关键修正点说明 #

• 局部累加变量：把total定义在sumProfit函数内部，确保每次创建Transform流时都从0开始累加，避免全局变量污染。
• 正确的flush配置：通过flush属性指定流结束时的回调，此时所有数据处理完成，再输出最终计算的总和。
• 移除多余解析：直接使用csvtojson输出的对象属性chunk.profit，省去不必要的JSON解析步骤。

修改后，整个流处理完成后只会输出一次最终的利润总和，符合需求。

内容的提问来源于stack exchange，提问作者T D