貓鼬：流聚合的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', ... 

不完全直觀，但它工作時，我試了一下。