2

我正在尝试使用事件流 nodejs 将 3 Mongoose find 查询的结果写入单个文件 test.txt。

我的程序是这样的……</p> 

var es = require('event-stream');
var fs = require('fs');
var wstream = fs.createWriteStream('TestFile.csv');

mongoose.connection.on('connected', function () {  

//First Find Query
Model.find({"FirstId":{$exist:true}).cursor()
.pipe(es.map(function (data, callback) {

 var csv = json2csv({data:formated, fields:fields, hasCSVColumnTitle:false});
  callback(null, csv)
  }))
  .pipe(wstream);

//Second find query
Model.find({"SecondId":{$exist:true}).cursor()
.pipe(es.map(function (data, callback) {
if(data.Email)
{  
  var csv = json2csv({data:formated, fields:fields, hasCSVColumnTitle:false});
}
else{
callback();
}
  callback(null, csv)
}))
.pipe(wstream);


 //Third find query
 Model.find({"ThirdId":{$exist:true}).cursor()
 .pipe(es.map(function (data, callback) {
 if(data.Email)
 {  
  var csv = json2csv({data:formated, fields:fields, hasCSVColumnTitle:false});
 }
 else{
 callback();
 }
  callback(null, csv)
 }))
 .pipe(wstream);

  });

在这个程序中，我可以将每个查找查询结果分别写入文件中。但是当我在一个程序中结合 3-find 查询时，它会抛出“write after end”错误。

谁能帮我解决这个错误？

谢谢大家的时间！

4

0 回答 0