Node.js中使用fast-csv无法向数组推送数据问题求助

嘿，这是Node.js异步操作里的典型坑！你现在的代码逻辑有个关键问题：流操作是异步的，但你在流还没处理完所有数据时，就已经返回响应了。

为什么会出现空数组？ #

fs.createReadStream和fast-csv的管道处理都是异步执行的，你的代码实际执行顺序是：

1. 初始化空数组data
2. 启动流解析CSV（这一步是非阻塞的，直接往下走）
3. 立刻执行return res.status(201).send(...)——这时候data还没被任何data事件填充，自然是空的！

而data事件和end事件都是在后续的事件循环里才会触发，你根本没等它们执行就把响应发出去了。

修正后的代码 #

把返回响应的逻辑移到end事件的回调里，只有当所有CSV行都处理完成后，才给客户端返回结果：

let data = [];
fs.createReadStream(req.file.path)
  .pipe(csv.parse({ ignoreEmpty: true, trim: true }))
  .on("error", (error) => {
    console.error(error);
    // 出错时必须返回响应，避免客户端一直等待请求结果
    return res.status(500).send({ status: "error", message: error.message });
  })
  .on("data", (row) => data.push(_.compact(row)))
  .on("end", (rowCount) => {
    console.log(`共处理了 ${rowCount} 行数据`);
    return res.status(201).send({ status: "success", data, rowCount });
  });

更现代的写法（异步迭代器） #

如果你使用的是Node.js 10+，可以用for await...of的异步迭代器写法，代码更简洁易懂，也避免了回调嵌套：

async function processUploadedCSV() {
  try {
    const data = [];
    // 创建CSV解析流
    const csvStream = fs.createReadStream(req.file.path)
      .pipe(csv.parse({ ignoreEmpty: true, trim: true }));

    // 异步遍历每一行数据
    for await (const row of csvStream) {
      data.push(_.compact(row));
    }

    // 所有行处理完成后返回响应
    return res.status(201).send({ status: "success", data });
  } catch (error) {
    console.error(error);
    return res.status(500).send({ status: "error", message: error.message });
  }
}

// 执行CSV处理函数
processUploadedCSV();

额外注意点 #

• 永远不要忽略error事件的处理：如果CSV解析出错（比如格式不符合预期），客户端会一直处于等待状态，必须在error回调里返回错误响应。
• 确保_.compact是正确引入的（比如你已经安装并导入了Lodash），不然这一步可能会导致数据处理异常，但你说没有报错，应该这部分没问题。

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