MongoDB月度交易数据聚合问题：分组未生效求助

我熟悉SQL，但刚接触MongoDB。当前需要将transactions集合与clients集合关联，把每日多笔交易按月度汇总，统计每个客户的月度交易总金额（USD_Value）和交易笔数用于分析。

原查询语句如下：

db.transactions.aggregate([
{
     $lookup:
     {
        from: 'clients',
        localField: 'client',
        foreignField: '_id',
        as: 'clients_docs'
     }
},
{
    $match:
    {
        clients_docs: { $ne: [] }
    }
},
{
     $addFields:
     {
         clients_docs:
         {
             $arrayElemAt: ["$clients_docs", 0]
         }
     }   
},
{
    $match:
    {
        $and:
        [
            { "updated_at": { $gte: ISODate("2022-01-01") } },
            { "updated_at": { $lte: ISODate("2022-01-31") } },
            
        ]
        ,"status": { $eq: "PAID" }
        ,"clients_docs.is_send_client": { $eq: true }
    }    
},
{
      $group:
      {
          _id: 
          { 
              year_month: { $dateToString: { "date": "$updated_at", "format": "%Y-%m"  } } 
              ,client_name: "$clients_docs.client_name"
              ,client_label: "$clients_docs.client_label"
              ,client_code: "$clients_docs.client_code"
              ,client_country: "$clients_docs.client_country"
              ,base_curr: "$clients_docs.client_base_currency"
              ,inv_curr: "$clients_docs.client_invoice_currency" 
              ,dest_curr: "$store.destination_currency"         
              ,total_vol: { $sum: "$USD_Value" }
              ,total_tran: { $sum: 1 }
          }
      }                 
},
{
    $limit: 10
}
])

但查询结果仅返回单条交易数据，未实现月度客户维度的聚合效果，推测分组逻辑有误，求修正方法。

错误原因 #

核心问题出在$group阶段的结构错误：你把聚合计算字段（total_vol、total_tran）放到了_id对象里。MongoDB的$group中，_id是分组的唯一标识键，只有分组依据字段才放在_id内，聚合统计字段必须放在$group顶层，和_id同级。

另外还有潜在问题：dest_curr: "$store.destination_currency"如果是交易维度的可变字段，不适合放在分组键里（除非同一客户同一月份的交易destination_currency完全一致），否则会导致同一客户月度内的交易被拆分到不同组。

修正后的查询语句 #

db.transactions.aggregate([
  // 关联clients集合
  {
    $lookup: {
      from: 'clients',
      localField: 'client',
      foreignField: '_id',
      as: 'clients_docs'
    }
  },
  // 过滤未关联到客户的交易
  {
    $match: {
      clients_docs: { $ne: [] }
    }
  },
  // 将关联结果数组转为单个对象
  {
    $addFields: {
      clients_docs: { $arrayElemAt: ["$clients_docs", 0] }
    }
  },
  // 过滤时间范围、交易状态和客户属性
  {
    $match: {
      "updated_at": { 
        $gte: ISODate("2022-01-01"), 
        $lte: ISODate("2022-01-31") 
      },
      "status": "PAID",
      "clients_docs.is_send_client": true
    }
  },
  // 按月度+客户维度分组聚合
  {
    $group: {
      _id: {
        year_month: { $dateToString: { date: "$updated_at", format: "%Y-%m" } },
        client_name: "$clients_docs.client_name",
        client_label: "$clients_docs.client_label",
        client_code: "$clients_docs.client_code",
        client_country: "$clients_docs.client_country",
        base_curr: "$clients_docs.client_base_currency",
        inv_curr: "$clients_docs.client_invoice_currency",
        // 若dest_curr是客户固定值则保留，否则注释/移除
        // dest_curr: "$store.destination_currency"
      },
      // 聚合统计字段放在$group顶层，与_id同级
      total_vol: { $sum: "$USD_Value" },
      total_tran: { $sum: 1 }
    }
  },
  // 可选：按总金额降序排序，方便查看头部数据
  {
    $sort: { total_vol: -1 }
  },
  {
    $limit: 10
  }
])

补充说明 #

• 分组键_id仅包含用于分组的维度（年月、客户标识类字段），确保同一客户同一月份的所有交易被归为一组。
• 聚合计算字段total_vol（总金额）和total_tran（交易笔数）放在$group顶层，MongoDB会对每个分组执行求和计算。
• 若dest_curr是交易级别的可变字段，不适合作为分组键，如需保留该字段，可改用$addToSet收集所有不同值，或$first取第一条交易的值，示例：dest_currs: { $addToSet: "$store.destination_currency" }。

内容的提问来源于stack exchange，提问作者starfly