Τι είναι το aggregation pipeline;

Question

Accepted Answer

Το **aggregation pipeline** είναι το ισχυρό framework της MongoDB για **επεξεργασία και ανάλυση δεδομένων** — περνάει τα documents μέσα από μια ακολουθία **stages**, όπου κάθε stage μετασχηματίζει τα δεδομένα (filtering, grouping, computing). Είναι το ισοδύναμο της MongoDB για το SQL GROUP BY και σύνθετα αναλυτικά queries, αλλά πιο ευέλικτο.

## The pipeline concept: stages transform data

```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
```

Τα documents ρέουν μέσα από τα stages με τη σειρά — κάθε stage τα μετασχηματίζει και περνάει τα αποτελέσματα στο επόμενο. Αυτό το pipeline υπολογίζει ανά πελάτη συνολικά, ταξινομημένα, top 10 — όπως ένα SQL GROUP BY query.

## Common pipeline stages

```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 — joining collections

```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` επιτρέπει joins (τα οποία η MongoDB συνήθως αποφεύγει μέσω embedding) — χρήσιμο όταν χρειάζεται να συνδυάσετε collections.

## $unwind — expand arrays

```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
]);
```

## Γιατί έχει σημασία

Το aggregation pipeline είναι ένα από τα πιο ισχυρά και σημαντικά features της MongoDB — είναι το πρωτεύον εργαλείο για **ανάλυση δεδομένων, αναφορές και σύνθετους μετασχηματισμούς**, επομένως η κατανόησή του είναι απαραίτητη για σοβαρή MongoDB δουλειά πέρα από βασικά queries.

Το **stage-based model** του pipeline (documents που ρέουν μέσα από διαδοχικά transformation stages, κάθε ένα κάνει filtering, grouping, reshaping ή computing) είναι εννοιολογικά κομψό και επιτρέπει sophisticated data processing που απλά `find` queries δεν μπορούν — είναι το ισοδύναμο της MongoDB για το SQL GROUP BY και αναλυτικά queries, αλλά πιο ευέλικτο και composable.

Η κατανόηση των κοινών stages — **`$match`** (filtering, ιδανικά νωρίς για μείωση δεδομένων), **`$group`** (grouping και aggregating με `$sum`, `$avg`, κ.λπ. — ο πυρήνας της analytics), **`$sort`/`$limit`** (ordering και pagination), **`$project`** (reshaping documents), **`$unwind`** (expanding arrays σε documents — σημαντικό για ανάλυση δεδομένων arrays, κοινό στη MongoDB), και **`$lookup`** (joining collections — επιτρέποντας τα joins που η MongoDB αλλιώς αποφεύγει) — καλύπτει το toolkit για πραγματική επεξεργασία δεδομένων.

Το pipeline χειρίζεται αναφορές, analytics, data transformation και σύνθετα queries (aggregations, joins, array processing) που είναι κοινές ανάγκες σε εφαρμογές.

Επειδή η ανάλυση δεδομένων και σύνθετη querying είναι σημαντικές χρήσεις οποιασδήποτε βάσης δεδομένων, και επειδή το aggregation pipeline είναι το ισχυρό, ευέλικτο μηχανισμό της MongoDB για αυτές (πολύ πέρα από βασικά CRUD), η κατανόηση του aggregation pipeline — το stage model και τα κύρια stages ($match, $group, $sort, $project, $unwind, $lookup) — είναι απαραίτητη, συχνά εφαρμοζόμενη MongoDB γνώση για analytics, αναφορές και σύνθετο data transformation, ένα κατάληκτο της advanced MongoDB δεξιότητας και ένα από τα πιο σημαντικά MongoDB topics για να πάρετε πραγματική αναλυτική αξία από τη βάση δεδομένων.