MongoDB 8.x 现代 NoSQL 数据架构完全指南 2026：分片集群 + 副本集 + 聚合管道 + 生产调优

1
                           [ 应用程序客户端 (App Client) ]
2
                                          │
3
                   ┌──────────────────────┴──────────────────────┐
4
                   │               mongos (无状态路由中枢)         │
5
                   │  - 解析查询条件，根据路由表将请求分发至对应分片  │
6
                   └──────────────────────┬──────────────────────┘
7
                                          │
8
                 ┌────────────────────────┼────────────────────────┐
9
                 ▼                        ▼                        ▼
10
    ┌─────────────────────────┐ ┌──────────────────┐ ┌─────────────────────────┐
11
    │    Shard 1 (数据分片1)   │ │Config Server 副本集│ │    Shard 2 (数据分片2)   │
12
    │  [Primary + Secondary]  │ │(存储集群元数据与路由)│ │  [Primary + Secondary]  │
13
    │  - 存储 Hash 0~N 数据   │ └──────────────────┘ │  - 存储 Hash N~MAX 数据 │
14
    └─────────────────────────┘                      └─────────────────────────┘

1
// 在 mongosh 中执行聚合分析
2
db.orders.aggregate([
3
  // 1. 过滤：只统计 2026 年已支付且金额大于 50 的订单
4
  {
5
    $match: {
6
      status: "PAID",
7
      created_at: { $gte: ISODate("2026-01-01T00:00:00Z") },
8
      total_amount: { $gt: 50.0 }
9
    }
10
  },
11

12
  // 2. 展开嵌套数组（将订单中的多个商品拆为独立流）
13
  {
14
    $unwind: "$items"
15
  },
16

17
  // 3. 多表关联：关联商品信息表（类似 SQL Left Join）
18
  {
19
    $lookup: {
20
      from: "products",
21
      localField: "items.product_id",
22
      foreignField: "_id",
23
      as: "product_details"
24
    }
25
  },
26
  {
27
    $unwind: "$product_details"
28
  },
29

30
  // 4. 按商品类目分组统计销售总额与销量
31
  {
32
    $group: {
33
      _id: "$product_details.category",
34
      total_revenue: { $sum: { $multiply: ["$items.price", "$items.quantity"] } },
35
      total_quantity_sold: { $sum: "$items.quantity" },
36
      unique_buyers: { $addToSet: "$user_id" }
37
    }
38
  },
39

40
  // 5. 投影重塑输出结果，计算购买人数
41
  {
42
    $project: {
43
      category: "$_id",
44
      total_revenue: { $round: ["$total_revenue", 2] },
45
      total_quantity_sold: 1,
46
      unique_buyer_count: { $size: "$unique_buyers" },
47
      _id: 0
48
    }
49
  },
50

51
  // 6. 按销售总额降序排列取 Top 10
52
  {
53
    $sort: { total_revenue: -1 }
54
  },
55
  {
56
    $limit: 10
57
  }
58
]);

1
// 示例：高效支持 db.orders.find({status: "PAID", amount: {$gt: 50}}).sort({created_at: -1})
2
db.orders.createIndex({ status: 1, created_at: -1, amount: 1 });

1
// 诊断查询性能
2
db.orders.find({ status: "PAID", user_id: 8801 }).explain("executionStats");
3

4
// 重点关注指标：
5
// 1. winningPlan.stage: 必须是 "IXSCAN" (索引扫描)，严禁出现 "COLLSCAN" (全表扫描)！
6
// 2. totalDocsExamined vs nReturned: 两者越接近 1:1 越好。若扫描 10000 篇只返回 1 篇，说明索引效率极低。