MongoDB聚合：多$sum分组统计中如何正确搭配$project阶段

报错核心原因 #

你遇到的Location40323报错，是MongoDB聚合语法的强校验规则触发的：聚合管道的每个数组元素，必须是仅包含一个管道操作符的独立阶段。
之前的错误写法把$project、$group两个独立的管道操作符，塞到了同一个大括号对象里，相当于单个管道阶段同时承载了两个不同的操作，完全不符合语法要求，直接触发校验失败。

语法修正的核心规则 #

聚合查询的入参是一个阶段数组，数组里的每一个元素，都要单独占一个独立的对象，通过结构对比就能清晰看出差异：

• 错误结构（触发40323报错）：

db.col.aggregate([
  // 单个对象里塞了$project和$group两个操作符
  {
    $project: { /* 投影规则 */ },
    $group: { /* 分组规则 */ }
  }
])

• 正确结构（无语法报错）：

db.col.aggregate([
  // 第一个独立阶段：$project
  { $project: { /* 投影规则 */ } },
  // 第二个独立阶段：$group
  { $group: { /* 分组规则 */ } }
])

结合业务需求的可运行实现 #

你的业务目标是按事件维度分组，同时输出分组汇总值与关联属性，结合语法规则可以拆成两个独立的管道阶段实现：

1. 第一阶段执行$group：完成分组维度的统计，用累加器完成数值求和、关联属性收集
2. 第二阶段执行$project：对$group的输出做字段裁剪、重命名，得到符合要求的返回结构

可直接运行的参考代码如下：

db.collection.aggregate([
  // 分组统计阶段
  {
    $group: {
      _id: "$EVENT_TYPE", // 按事件类型分组
      // 数值求和汇总
      totalPropCost: { $sum: "$DAMAGE_PROPERTY" },
      totalDeaths: { $sum: "$DEATHS_DIRECT" },
      totalInjury: { $sum: "$INJURIES_DIRECT" },
      totalCropCost: { $sum: "$DAMAGE_CROPS" },
      // 收集分组下的关联属性
      relatedInfo: {
        $push: {
          registeredDate: "$BEGIN_DATE_TIME",
          stateName: "$STATE",
          damageCost: "$DAMAGE_PROPERTY",
          peopleCost: "$DEATHS_DIRECT",
          injuryCost: "$INJURIES_DIRECT",
          cropCost: "$DAMAGE_CROPS"
        }
      }
    }
  },
  // 投影裁剪阶段（独立对象，无语法报错）
  {
    $project: {
      _id: 0,
      eventName: "$_id",
      totalPropCost: 1,
      totalDeaths: 1,
      totalInjury: 1,
      totalCropCost: 1,
      relatedInfo: 1
    }
  }
])

常见实操注意点 #

• 不要随意调换$project和$group的顺序：如果把$project放在$group前面，这个阶段过滤/重命名后的字段，才是$group阶段可以访问的字段——比如你提前把EVENT_TYPE映射成了eventName，后面$group就不能再引用原始的EVENT_TYPE字段了，因为前一阶段已经把这个字段从输出里移除了。
• 如果不需要收集分组下的全量明细属性，可以用$first类累加器取同组的代表属性，避免返回冗余的大数组结构。
• 你的样本数据里，DAMAGE_PROPERTY、DAMAGE_CROPS字段是带K/M单位的字符串，不是纯数字，直接做$sum是无法得到准确汇总值的，需要在分组前增加字段转换逻辑，把字符串转成数值后再参与统计。

内容的提问来源于stack exchange，提问作者Data Science Analytics Manager