Mongoose：ストリーミング集約JSONデータ

Question

タイトルに示されているように、私はwebappにExpressを使用しています。

現在、私のコードは次のようなものになります。

APIコントローラの代わりに使用してvar stream = Doc.find().stream();の

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(); 
    }); 

}; 

を、私はaggregate()の利用をしたいです。

find()のように、aggregate()は読み込み可能なストリームであると思われます。

しかし、find()をaggregate()コールに置き換えただけでは機能しないようです。

「TypeError：Object #<Aggregate> has no method 'stream'」と表示されます。集約されたJSONデータストリーミングの代替手段？

Answer 1

あなたはそれを実行する前Aggregateにcursor()を呼び出した場合、その後のexec()は、あなたがその結果をストリーミングするためにstream()を呼び出すことができるネイティブのカーソルを返します。

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

直感的ではありませんが、試してみるとうまくいきました。