Node.js中fast-csv异步读取文件后数组为空的解决方法

这问题我太熟了！异步操作的执行顺序坑真的很容易踩，咱们来一步步搞定它～

问题根源 #

你说得没错，fast-csv的流操作是异步非阻塞的：当你调用fs.createReadStream和pipe之后，JavaScript引擎不会等着整个CSV文件读完才继续执行后面的代码，而是直接跳到外面的console.log("DISHTYPES",dishTypes)——这时候数据还没开始往数组里推呢，所以数组是空的。而end事件要等所有数据读取完成才会触发，这时候你才能拿到完整的dishTypes数组。

解决方案1：把代码移到end事件回调里 #

最直接的办法就是把需要在数据读取完成后执行的逻辑，全部放到end事件的回调函数里：

var fs = require('fs');
var csv = require('fast-csv');
const dishTypes = [];

fs.createReadStream('dishtypes_id.csv')
  .pipe(csv())
  .on('data', function (data) {
    dishTypes.push(data)
  })
  .on('end', function () {
    // 所有数据都读取完成后才执行这里的代码
    console.log("DISHTYPES", dishTypes);
    console.log("END", dishTypes.length); // 这里就能输出3839啦
  });

这样一来，只有当end事件触发（也就是CSV全部读完），才会打印填充好的数组，完美解决顺序问题。

解决方案2：用Promise+async/await封装（适合复杂流程） #

如果你的业务逻辑还有其他异步操作，把读取CSV的逻辑封装成Promise会让代码结构更清晰，还能用上async/await的同步写法：

var fs = require('fs');
var csv = require('fast-csv');

// 封装读取CSV的Promise函数
function readCsv(filePath) {
  return new Promise((resolve, reject) => {
    const dishTypes = [];
    fs.createReadStream(filePath)
      .pipe(csv())
      .on('data', (row) => dishTypes.push(row))
      .on('end', () => resolve(dishTypes)) // 成功时返回填充好的数组
      .on('error', (err) => reject(err)); // 别忘了处理读取错误哦
  });
}

// 用async/await调用
async function processDishTypes() {
  try {
    const dishTypes = await readCsv('dishtypes_id.csv');
    console.log("DISHTYPES", dishTypes);
    console.log("END", dishTypes.length);
  } catch (error) {
    console.error('读取CSV文件失败:', error);
  }
}

processDishTypes();

这种方式的好处是，你可以把读取CSV和后续的业务逻辑（比如存数据库、处理数据）用同步的写法串联起来，代码可读性更高。

小提醒 #

原来的end事件回调里的data参数其实是没用的哦～fast-csv的end事件不会传递数据参数，你之前看到的END 3839应该是巧合（可能是某个旧版本的返回值，或者变量提升导致的），正确获取行数的方式是用dishTypes.length。

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