Što je pipeline agregacije?

Question

Accepted Answer

**Pipeline agregacije** je MongoDB-ov moćan okvir za **obradu i analizu podataka** — prosleđuje dokumente kroz niz **faza**, od kojih svaka transformira podatke (filtriranje, grupiranje, računanje). To je MongoDB-ov ekvivalent SQL-ovom GROUP BY i kompleksnim analitičkim upitima, ali fleksibilniji.

## Koncept pipeline-a: faze transformiraju podatke

```js
db.orders.aggregate([
  { $match: { status: "completed" } },          // 1. FILTER (like WHERE)
  { $group: {                                    // 2. GROUP and aggregate
      _id: "$customerId",                         //    group by customerId
      total: { $sum: "$amount" },                 //    sum amounts per customer
      count: { $sum: 1 }                          //    count orders
  }},
  { $sort: { total: -1 } },                       // 3. SORT by total
  { $limit: 10 }                                  // 4. top 10
]);
// documents flow through each stage; each stage's output feeds the next
```

Dokumenti teku kroz faze redom — svaka faza ih transformira i prosleđuje rezultate sljedećoj. Ovaj pipeline računa ukupne vrijednosti po kupcu, sortirane, prvih 10 — kao SQL GROUP BY upit.

## Uobičajene faze pipeline-a

```text
$match    → filter documents (like WHERE) — put EARLY to reduce data
$group    → group by a key and aggregate ($sum, $avg, $max, $min, $push, etc.)
$sort     → order documents
$project  → reshape documents (include/exclude/compute fields)
$limit / $skip → pagination
$unwind   → deconstruct an array field into multiple documents (one per element)
$lookup   → JOIN with another collection
$addFields → add computed fields
$count    → count documents
```

## $lookup — spajanje kolekcija

```js
// $lookup performs a left-outer JOIN to another collection
db.orders.aggregate([
  { $lookup: {
      from: "customers",
      localField: "customerId",
      foreignField: "_id",
      as: "customer"           // joined customer data added as an array field
  }}
]);
```

`$lookup` omogućava spajanja (što MongoDB inače izbjegava putem ugniježđavanja) — korisno kada trebate kombinirati kolekcije.

## $unwind — proširenje nizova

```js
// turn one document with an array into multiple documents (one per array element)
db.posts.aggregate([
  { $unwind: "$tags" },                           // one doc per tag
  { $group: { _id: "$tags", count: { $sum: 1 } } } // count posts per tag
]);
```

## Zašto je važno

Pipeline agregacije je jedna od MongoDB-ovih najmoćnijih i najvažnijih mogućnosti — to je primarni alat za **analizu podataka, izvještavanje i kompleksne transformacije**, pa je razumijevanje tog pipeline-a bitno za ozbiljniji MongoDB rad izvan osnovnih upita.

**Model baziran na fazama** pipeline-a (dokumenti koji teku kroz sekvencijalne faze transformacije, od kojih svaka filtrira, grupira, preoblikuje ili računa) je konceptualno elegantan i omogućava sofisticirane obrade podataka koje jednostavni `find` upiti ne mogu — to je MongoDB-ov ekvivalent SQL-ovom GROUP BY i analitičkim upitima, ali fleksibilniji i kompozitibilniji.

Razumijevanje uobičajenih faza — **`$match`** (filtriranje, idealno rano kako bi se reducirala količina podataka), **`$group`** (grupiranje i agregacija sa `$sum`, `$avg`, itd. — jezgra analitike), **`$sort`/`$limit`** (sortiranje i paginacija), **`$project`** (preoblikovanje dokumenata), **`$unwind`** (proširenje nizova u dokumente — važno za analizu podataka u nizu, što je često u MongoDB-u) i **`$lookup`** (spajanje kolekcija — omogućavanje spajanja koja MongoDB inače izbjegava) — pokriva alate potrebne za stvarnu obradu podataka.

Pipeline obrađuje izvještavanje, analitiku, transformaciju podataka i kompleksne upite (agregacije, spajanja, obradu nizova) koji su česti zahtjevi u aplikacijama.

Budući da su analiza podataka i kompleksno upitavanje važne namjene bilo kojeg sustava baza podataka, i budući da je pipeline agregacije MongoDB-ov moćan, fleksibilan mehanizam za njih (odlazno daleko izvan osnovnog CRUD-a), razumijevanje pipeline-a agregacije — modela faza i ključnih faza ($match, $group, $sort, $project, $unwind, $lookup) — je bitno, često primjenjivano MongoDB znanje za analitiku, izvještavanje i kompleksne transformacije podataka, znak napredne MongoDB vještine i jedno od najvažnijih MongoDB tema za dobivanje stvarne analitičke vrijednosti iz baze podataka.