聚合操作概述

MongoDB的聚合操作是对数据进行分组、过滤、排序和计算等处理的方法。聚合管道（Aggregation Pipeline）就是实现这些操作的工具，它由一系列有序的聚合阶段（Aggregation Stage）组成，每个阶段执行特定任务，如过滤、投影或分组。通过这些阶段，输入文档可以被处理并输出新的文档。

常用聚合阶段

以下是一些常见的聚合阶段：

1. $match：筛选符合条件的文档，类似于查询。
2. $project：选择特定字段或创建新字段，用于限制返回字段或转换字段类型。
3. $group：对文档进行分组，并对每组执行如求和、计数等聚合操作。
4. $sort：对文档进行排序。
5. $limit：限制返回文档数量。
6. $skip：跳过指定数量的文档。
7. $unwind：展开数组字段，将数组元素转化为独立文档。
8. $lookup：在多个集合间进行关联查询，相当于SQL中的JOIN操作。
9. $facet：在单个管道中执行多个聚合操作，并将结果分组输出。

聚合管道示例

通过组合多个阶段，可以构建复杂的数据处理逻辑。例如，计算每个用户的平均消费金额和最近一次购买日期，或者统计每个用户购买商品种类数。这些都可以通过灵活使用不同的聚合阶段来实现。

需要注意的是，尽管功能强大，但聚合管道性能可能不如简单查询。因此，应根据数据量和查询复杂度选择适当的索引和阶段顺序，以提升性能。

$facet使用案例详解

$facet 是一个强大的工具，用于在单个聚合管道内执行多个独立的子任务，并将结果组合输出。它允许我们在一个管道中同时处理多项任务，非常适用于复杂的数据分析场景。

示例代码

db.collection.aggregate([
  {
    $facet: {
      output1: [...],
      output2: [...],
      ...
    }
  }
])

在这个示例中，$facet 接受一个包含多个子文档的对象作为参数，每个子文档定义了一系列要执行的聚合操作。这些子集会并行处理输入数据流，然后分别输出结果。

输出示例

{
  "output1": [...],
  "output2": [...]
}

上面的输出展示了 output1 和 output2 的结果，它们对应于 $facet 定义中的标识符及其相关联的聚合操作序列。

实际应用场景

假设我们想同时计算每个用户的平均消费金额、最近一次购买日期以及购买商品种类数，可以这样做：

db.orders.aggregate([
  { $match: { "status": "complete" } },
  {
    $facet: {
      avgAmount: [
        { $group: { _id: "$user_id", avgAmount: { $avg: "$amount" } } }
      ],
      lastPurchase: [
        { $sort: { "purchase_date": -1 } },
        { $group: { _id: "$user_id", lastPurchase: { $first: "$purchase_date" } } }
      ],
      numCategories: [
        { $group: { _id: "$user_id", numCategories: { $addToSet: "$category" } } },
        { $project:{ _id : 1, numCategories : {$size:"$numCategories"}}}
      ]
    }
  }
])

在这个示例中，我们首先使用 $match 筛选出已完成订单，然后通过 $facet 将数据划分成三个子集分别计算平均消费金额、最近一次购买日期以及购买商品种类数。这样不仅减少了管道数量，还提高了效率和可维护性。