Node.js使用csv模块如何同步读取两个CSV文件？

嘿，我来帮你搞定这个问题！你用Node.js的csv模块处理两个CSV文件，还在纠结怎么实现同步读取对吧？先给你吃个定心丸：为每个CSV创建单独的处理逻辑完全没问题，不过Node.js本身是异步优先的，我们可以用几种方式实现“同步读取”的效果——也就是等两个文件都读取解析完成后，再继续后续的处理。

下面给你两种实用的方案，按需选择：

方案一：异步并行读取（推荐，性能更好） #

Node.js里异步并行是更优的选择，不会阻塞事件循环。我们可以把每个CSV的读取解析过程包装成Promise，然后用Promise.all等待两个任务都完成，再用async/await写出同步风格的代码。

首先确保你已经安装了csv模块：

npm install csv

然后是代码示例：

const fs = require('fs');
const csv = require('csv');

// 把CSV读取解析逻辑包装成Promise
function readAndParseCSV(filePath) {
  return new Promise((resolve, reject) => {
    const parsedData = [];
    // 创建文件读取流， pipe到csv解析器
    fs.createReadStream(filePath)
      .pipe(csv.parse({ columns: false })) // 这里如果你的CSV有表头，可以改成columns: true，解析后会返回对象
      .on('data', (row) => parsedData.push(row)) // 每解析一行就存入数组
      .on('end', () => resolve(parsedData)) // 解析完成后返回数据
      .on('error', (err) => reject(err)); // 捕获错误
  });
}

// 用async/await实现同步风格的并行读取
async function loadAllCSVData() {
  try {
    // 同时启动两个读取任务，等待两者都完成
    const [areaCodeData, callData] = await Promise.all([
      readAndParseCSV('./us-area-code-cities.csv'),
      readAndParseCSV('./sampleData.csv')
    ]);

    // 到这里两个文件的数据都已经准备好了，随便造作！
    console.log('前2条区号数据:', areaCodeData.slice(0, 2));
    console.log('前2条呼叫数据:', callData.slice(0, 2));

    // 比如你可以在这里做数据关联：提取呼叫号码的区号，匹配对应的经纬度
  } catch (error) {
    console.error('读取解析CSV时出错:', error);
  }
}

// 执行函数
loadAllCSVData();

关键点说明： #

• csv.parse的columns配置很实用：如果你的us-area-code-cities.csv第一行是表头（比如area_code,city,state,country,lat,lng），把columns: true开启后，每一行会变成{ area_code: '201', city: 'Bayonne', ... }这样的对象，处理起来更直观。
• Promise.all是并行执行两个读取任务，比串行读取（先读第一个再读第二个）效率高很多，尤其是文件较大的时候。

方案二：同步读取解析（不推荐，仅适用于小文件） #

如果你确实需要完全同步的方式（会阻塞Node.js事件循环，大文件慎用），可以先用fs.readFileSync读取文件内容，再用csv模块的同步解析方法：

const fs = require('fs');
const csv = require('csv');

try {
  // 同步读取文件内容
  const areaCodeFileContent = fs.readFileSync('./us-area-code-cities.csv', 'utf8');
  const callFileContent = fs.readFileSync('./sampleData.csv', 'utf8');

  // 同步解析CSV内容
  const areaCodeData = csv.parse.sync(areaCodeFileContent, { columns: false });
  const callData = csv.parse.sync(callFileContent, { columns: false });

  // 处理数据
  console.log('区号数据:', areaCodeData.slice(0, 2));
  console.log('呼叫数据:', callData.slice(0, 2));
} catch (error) {
  console.error('同步读取解析出错:', error);
}

注意： #

这种方式会阻塞Node.js的事件循环，直到两个文件都读取解析完成，所以只适合处理小体积的CSV文件，否则会影响应用的响应性。

最后再回应你的小疑问：你之前为每个CSV创建单独的csv对象完全没问题，不过其实csv模块的parse方法是无状态的，你不需要特意创建多个对象，重复调用parse方法或者像上面代码那样处理就好，不会有冲突~

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