什么是聚合管道？

Question

什么是聚合管道？

Accepted Answer

**聚合管道**是MongoDB强大的框架，用于**数据处理和分析** — 它通过一系列**阶段**传递文档，每个阶段都转换数据（筛选、分组、计算）。它是MongoDB对SQL的GROUP BY和复杂分析查询的等价物，但更灵活。

## 管道概念：阶段转换数据

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

文档按顺序通过各个阶段 — 每个阶段转换它们并将结果传递到下一个。此管道计算每个客户的总计、排序、前10名 — 就像SQL GROUP BY查询。

## 常见的管道阶段

```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 — 连接集合

```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`支持连接（MongoDB通常通过嵌入来避免连接） — 当你需要组合集合时很有用。

## $unwind — 展开数组

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

## 为什么这很重要

聚合管道是MongoDB最强大和最重要的特性之一 — 它是**数据分析、报告和复杂转换**的主要工具，因此理解它对于超越基本查询的严肃MongoDB工作至关重要。

管道的**基于阶段的模型**（文档通过顺序转换阶段流动，每个阶段筛选、分组、重塑或计算）在概念上很优雅，能够进行简单`find`查询无法完成的复杂数据处理 — 它是MongoDB对SQL的GROUP BY和分析查询的等价物，但更灵活和可组合。

理解常见的阶段 — **`$match`**（筛选，理想情况下在早期减少数据）、**`$group`**（使用`$sum`、`$avg`等进行分组和聚合 — 分析的核心）、**`$sort`/`$limit`**（排序和分页）、**`$project`**（重塑文档）、**`$unwind`**（将数组展开为文档 — 对于分析数组数据很重要，在MongoDB中很常见）和**`$lookup`**（连接集合 — 支持MongoDB通常避免的连接） — 涵盖了真实数据处理的工具包。

管道处理报告、分析、数据转换和复杂查询（聚合、连接、数组处理），这些是应用程序中的常见需求。

由于数据分析和复杂查询是任何数据库的重要用途，而且聚合管道是MongoDB为其提供的强大灵活的机制（远超基本CRUD），理解聚合管道 — 阶段模型和关键阶段（$match、$group、$sort、$project、$unwind、$lookup） — 是必不可少的、经常应用的MongoDB知识，用于分析、报告和复杂数据转换，是高级MongoDB技能的标志，也是从数据库中获取真实分析价值的最重要的MongoDB主题之一。