如何按多个字段对一组子文档进行分组？

如何解决如何按多个字段对一组子文档进行分组？

我已经花了一天的大部分时间在这上面，现在已经没有想法了。这是我的收藏：

[
  {
    "_id": "ID_XXX","logs": [
      {
        "lead_id": 123,"list_id": "list_44","order_id": "order_1"
      },{
        "lead_id": 124,"order_id": "order_2"
      }
    ]
  },{
    "_id": "ID_YYY","logs": [
      {
        "lead_id": 125,"order_id": "order_2"
      },{
        "lead_id": 126,{
        "lead_id": 127,"order_id": "order_3"
      },{
        "lead_id": 128,"list_id": "list_66","order_id": "order_3"
      }
    ]
  }
]

我只是想获得 list_id 和 order_id 的计数，同时保留它们所在文档的 _id。这是我想要的输出：

[
  {
    "_id": "ID_XXX","counts": [
      {
        "lists": {"list_44": 2},},{
        "orders": {"order_1": 1,"order_2": 1}
      }
    ]
  },"counts": [
      {
        "lists": {"list_44": 3,"list_66": 1},{
        "orders": {"order_2": 2,"order_3": 2}
      }
    ]
  }
]

我尝试了太多汇总变体，无法在此列出，但最新的是：

db.collection.aggregate([
  {
    $unwind: "$logs"
  },{
    $group: {
      _id: "$_id",lists: {
        $push: "$logs.list_id"
      },orders: {
        $push: "$logs.order_id"
      }
    }
  }
])

这并没有给我我想要的。任何人都可以指出我正确的方向吗？这是游乐场链接：https://mongoplayground.net/p/f-jk7lbSrJ0

解决方法

• $reduce 迭代 logs 的循环，使用 logs、$objectToArray 将 $concatArrays 对象转换为 k(key) v(value) 格式的数组$reduce 中的初始值，
• $filter 以上将结果缩减为输入并过滤 logs 中的必填字段
• $unwind 解构 logs 数组

db.collection.aggregate([
  {
    $addFields: {
      logs: {
        $filter: {
          input: {
            $reduce: {
              input: "$logs",initialValue: [],in: { $concatArrays: ["$$value",{ $objectToArray: "$$this" }] }
            }
          },cond: { $in: ["$$this.k",["list_id","order_id"]] }
        }
      }
    }
  },{ $unwind: "$logs" },

• $group 通过 _id 和 logs 对象并使用 $sum
获取总数

  {
    $group: {
      _id: {
        _id: "$_id",logs: "$logs"
      },counts: { $sum: 1 }
    }
  },

• $group by _id 并制作 lists 数组，如果 logs.k 为 list_id，否则以 k 和 v 格式返回 $$REMOVE，同for orders 在 order_id
的基础上创建一个订单数组
• $addFields 使用 $arrayToObjectlistsorders` 数组将 and same as for 数组从 k 和 v 格式转换为对象格式

  {
    $group: {
      _id: "$_id._id",lists: {
        $push: {
          $cond: [
            { $eq: ["$_id.logs.k","list_id"] },{
              k: "$_id.logs.v",v: "$counts"
            },"$$REMOVE"
          ]
        }
      },orders: {
        $push: {
          $cond: [
            { $eq: ["$_id.logs.k","order_id"] },"$$REMOVE"
          ]
        }
      }
    }
  },{
    $addFields: {
      lists: { $arrayToObject: "$lists" },orders: { $arrayToObject: "$orders" }
    }
  }
])

Playground