Mungo: Streaming Aggregierte JSON-Daten

Question

Wie der Titel angegeben hat, verwende ich Express für meine Webapp.

Derzeit mein Code sieht ungefähr so ​​aus:

API-Controller

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

}; 

Statt mit var stream = Doc.find().stream(); möchte ich den Einsatz von aggregate() machen.

Wie find(), aggregate() soll ein lesbarer Stream sein, oder?

Doch als ich einfach find() durch einen aggregate() Aufruf ersetzt, scheint es nicht zu funktionieren.

Es heißt TypeError: Object #<Aggregate> has no method 'stream'. Was ist eine Alternative für das Streaming von aggregierten JSON-Daten?

Answer 1

Wenn Sie cursor() auf dem Aggregate aufrufen, bevor sie die nachfolgende exec() gibt einen nativen Cursor ausführt, die Sie dann stream() aufrufen können auf die Ergebnisse zu streamen.

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

Nicht genau intuitiv, aber es funktionierte, als ich es versuchte.