将异步与流 node.js 一起使用时报告错误

Question

我在尝试从读取文件并通过 csv-parse 管道传输的函数报告错误时遇到问题。我想要做的是，如果有一行没有三个字段，我想报告一个错误 - 到 async.series 调用。第一个实现失败，因为

function insertCsvIntoObject(done) {
    fs.createReadStream(inputCsvFilepath)
    .pipe(csvParser)
    .on('data', function (csvRow) {
        console.log('csv row:', csvRow);
        if (csvRow.length !== 3) {
            this.emit('error', "Does this go anywhere?");
        }
    })
    .on('end', function () {
         done(null, "Finished reading through the csv data");
     })
    .on('error', function (err) {
         console.log('errors is now:', csvReadErrors);
         done(new Error('Error reading csv file'), "CSV Parse error");
    });
}

这给出了一个 例外：[错误：回调已被调用。]如果我们在 csv 文件中有多个有问题的行。

在完成之前添加一个返回

return done(new Error('Error reading csv file'), "CSV Parse error");

也无济于事，因为我们无法停止并从父函数 - insertCsvIntoObject 返回。

此外，如果有任何错误事件，.on('end',..) 事件永远不会被触发。

在这种情况下报告错误的正确方法是什么？

Answer 1

当一行的列数不一致时，csv-parse 似乎已经发出错误。换句话说，你不应该自己发出一个。

为了防止回调被多次调用，可以使用once这样的封装：

function insertCsvIntoObject(done) {
  done = once(done);
  ...
};

理想情况下，您应该能够在第一个错误后结束处理，但我无法阻止解析器解析其他记录（this.end() 似乎不起作用，但也许我错过了东西）。