node.js – 以每秒1行的速率解析CSV

我一直试图找到库(以避免重新发明轮子)读取CSV文件中的单行并将值推送到下游进程.

但是,我需要读取和处理每秒只发生一次.有没有办法在Node上执行此操作？

解决方法

我最近遇到了类似的问题,因为我需要一种方法一次读取一行文件而不是移动到下一行,直到我完成处理前一行.

我通过使用promises,stream.pause()和stream.resume()解决了它.你可以这样做：

const Promise = require('bluebird');                        
const fs = require('fs');                                   
const byline = require('byline');                           

function readCSV(file,callback) {
  let stream = fs.createReadStream(file);
  stream = byline.createStream(stream);
  stream.on('data',(line) => {
    stream.pause();
    Promise.resolve(line.toString())
      .then(callback)
      .then(() => setTimeout(() => stream.resume(),1000));
  });
}

readCSV('file.csv',console.log);