De resultaten die uit de aggregatiepijplijn worden geretourneerd, zijn gewone objecten. U doet het sorteren dus als een pijplijnfase, niet als een afzonderlijke bewerking:
Recommend.aggregate(
[
// Grouping pipeline
{ "$group": {
"_id": '$roomId',
"recommendCount": { "$sum": 1 }
}},
// Sorting pipeline
{ "$sort": { "recommendCount": -1 } },
// Optionally limit results
{ "$limit": 5 }
],
function(err,result) {
// Result is an array of documents
}
);
Er zijn dus verschillende pijplijnoperators die kunnen worden gebruikt om $group
of $sort
of $limit
en ook andere dingen. Deze kunnen in willekeurige volgorde worden gepresenteerd, en zo vaak als nodig is. Gewoon begrijpen dat de ene "pijplijn"-fase leidt tot de volgende om naar te handelen.