猫鼬：流聚合的JSON数据

Question

正如标题所示，我正在使用Express为我的web应用程序。

目前，我的代码看起来是这样的：

API控制器

var mongoose = require('mongoose'); 
var Doc = mongoose.model('Document'); 

var sendJSONresponse = function(res, status, content) { 
    res.status(status); 
    res.json(content); 
}; 

// "/api/documents" 
module.exports.listAllDocuments = function(req, res) { 

    var stream = Doc.find().stream(); 
    stream.on('data', function (chunk) { 
    res.write(JSON.stringify(chunk)); 
    }).on('error', function (err) { 
    console.log('Error: ' + err); 
    }).on('end', function() { 
    res.end(); 
    }); 

}; 

而不是使用var stream = Doc.find().stream();的，我想使用的aggregate()。

像find(),aggregate()应该是一个可读的流，对不对？

然而，当我简单地用aggregate()呼叫替换find()时，它似乎不起作用。

它说类型错误：Object #<Aggregate> has no method 'stream'。什么是替代流式汇总JSON数据？

Answer 1

如果你在执行前呼吁Aggregatecursor()，随后exec()返回本地光标然后您可以致电给stream()流的结果。

var stream = Doc.aggregate(pipeline).cursor().exec().stream(); 
stream.on('data', ... 

不完全直观，但它工作时，我试了一下。