Pipeline agregacji przetwarza dokumenty przez uporządkowane etapy takie jak $match, $group, $project czy $sort. Każdy etap transformuje strumień i przekazuje wynik do następnego, umożliwiając złożone analizy podobne do SQL.
[
{ "$match": { "status": "paid" } },
{ "$group": { "_id": "$customerId", "total": { "$sum": "$amount" } } },
{ "$sort": { "total": -1 } }
]Rozwinięcie krótkiej odpowiedzi — co zwykle ma znaczenie w praktyce:
Poniżej dodatkowy przykład (bazuje na tym, co już jest w odpowiedzi):
[
{ "$match": { "status": "paid" } },
{ "$group": { "_id": "$customerId", "total": { "$sum": "$amount" } } },
{ "$sort": { "total": -1 } }
]