Node.js:管道传输文件时出现 ECONNRESET 错误

Question

我在 Node 中“管道”文件时遇到此错误:

events.js:160
  throw er; // Unhandled 'error' event
  ^
Error: read ECONNRESET
at exports._errnoException (util.js:1022:11)
at Pipe.onread (net.js:569:26)

这是我的代码:

var json_file = fs.createWriteStream(jsonFile),
    processes = 0,
    read_ended_flag = false,
    converter = new Converter(params);

let read_csv_file = fs.createReadStream(csvFilePath);

// For each csv line, we get a json doc
converter.on('record_parsed', jsonObj => {
    processes++;

    json_file.write(JSON.stringify(jsonObj) + '\n', () => {
        processes--;

        if(read_ended_flag && processes == 0){
            json_file.end();
            callback();
        }
    });
});

converter.on('end_parsed', () => {
    read_ended_flag = true;
});

read_csv_file
    .pipe(converter);

我尝试使用 this 捕获错误或this ，但还是一样。此错误仅在处理小文件(> 100 行)时出现。

是否是因为在写入新文件之前关闭了读取流？

非常感谢您的任何提示和帮助!

Answer 1

我找到了解决办法! :)

这是由于我的转换器参数(csvtojson模块)，我将workerNum设置为4，而我必须设置1来处理小文件。

workerNum: Number of worker processes. The worker process will use multi-cores to help process CSV data. Set to number of Core to improve the performance of processing large csv file. Keep 1 for small csv files. Default 1.

Here是关于csvtojson模块的完整教程

希望对其他人有帮助!