nodeJS异步函数解析csv返回数据到其他文件

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

async function parseCSVAndWriteToFile(csvFilePath, outputFilePath) {
  return new Promise((resolve, reject) => {
    const writeStream = fs.createWriteStream(outputFilePath);
    
    fs.createReadStream(csvFilePath)
      .pipe(csv())
      .on('data', (data) => {
        // 处理每一行数据
        // 可以根据需要进行数据处理、转换等操作
        // 例如，将数据转换为JSON格式
        const jsonData = JSON.stringify(data);
        
        // 将转换后的数据写入到目标文件
        writeStream.write(jsonData);
      })
      .on('end', () => {
        // 解析完成，关闭写入流
        writeStream.end();
        resolve();
      })
      .on('error', (error) => {
        reject(error);
      });
  });
}

const csvFilePath = 'path/to/input.csv';
const outputFilePath = 'path/to/output.json';

parseCSVAndWriteToFile(csvFilePath, outputFilePath)
  .then(() => {
    console.log('CSV解析完成并数据写入到文件成功');
  })
  .catch((error) => {
    console.error('CSV解析出错:', error);
  });