使用 fast-csv 同步处理 csv 文件

Question

我正在尝试使用 fast-csv 处理 csv 文件，这是我的代码。

    var stream = fs.createReadStream("sample.csv");
    csv.fromStream(stream, {headers : true})
    .on("data", function(data) {
            console.log('here');
            module.exports.saveData(data, callback)
        })
    .on("end", function(){
        console.log('end of saving file');
    });

    module.exports.saveData = function(data) {
    console.log('inside saving')
    }

我面临的问题是过程不同步。 我看到的输出类似于

这里
这里
内部储蓄
里面保存

但是，我想要的是

这里
内部储蓄
这里
里面保存

我假设我们需要使用 async.series 或 async.eachSeries 但不完全确定如何在这里使用它。非常感谢任何输入

提前致谢！

Answer 1

您可以暂停解析器，等待saveData 完成，然后恢复解析器：

var parser = csv.fromStream(stream, {headers : true}).on("data", function(data) {
  console.log('here');
  parser.pause();
  module.exports.saveData(data, function(err) {
    // TODO: handle error
    parser.resume();
  });
}).on("end", function(){
  console.log('end of saving file');
});

module.exports.saveData = function(data, callback) {
  console.log('inside saving')
  // Simulate an asynchronous operation:
  process.setImmediate(callback);
}