使用 MongoDB 嵌套 Group By 函数

Question

我对 MongoDB 很陌生，是 MySQL 的老手，但遇到了一个小障碍。

给定以下示例数据：
TeamID 日订单金额
100    4/1  50
100    4/1  40
200    4/2  50
100      4/2   20

我正在尝试查找团队每天的平均订单量。我可以使用 mapReduce 函数进行简单的查询，以使用 TeamId 和 TeamId 进行分组。天。所以现在我有：

TeamID     Day      AvgAmount
100        4/1   45
200        4/2   50
100         4/2     20

现在我正在尝试汇总这些数据获取每个团队每天的平均订单金额，即：

Day      AvgAmount
4/1     47.5
4/2      35

我可以使用 MySQL 轻松完成此操作，但无法弄清楚如何使用 MongoDB 执行此操作，而无需在应用程序端手动执行此操作，而不是使用MongoDB。

Answer 1

您可以使用 map-reduce 或 group() 功能。我使用 group() 是因为它更简单、更快，但是如果您需要将查询分布在分片集群上，则应该使用 map-reduce。

首先加载数据：

db.orders.insert( { teamid: 100, date: "4/1", amount: 50 })
db.orders.insert( { teamid: 100, date: "4/1", amount: 40 })
db.orders.insert( { teamid: 200, date: "4/2", amount: 50 })
db.orders.insert( { teamid: 100, date: "4/2", amount: 20 })

每个团队，每天：

db.orders.group({
    key: { teamid: true, date: true },
    reduce: function(doc, out) { out.sum += doc.amount; out.count++; },
    initial: { sum: 0, count: 0 },
    finalize: function(out) { out.average = out.sum / out.count }
});

要汇总每日汇总，只需更改键：

db.orders.group({
    key: { date: true },
    reduce: function(doc, out) { out.sum += doc.amount; out.count++; },
    initial: { sum: 0, count: 0 },
    finalize: function(out) { out.average = out.sum / out.count }
});

Answer 2

经过一番研究后，我想出了一个解决方案。由于对 MongoDB 和映射/归约思维不熟悉，我不满意它是最优化的解决方案，因此如果其他人有更好的解决方案，请纠正我。具体来说，我无法获得 arr_team 对象的长度，因此我必须有一个递增的计数器。

减少功能：

    function(doc, prev) { 
      var retVal  = {team_count: 0, day_total: 0};

      if(!prev.arr_team[doc.team_id]) {
        prev.arr_team[doc.team_id] = 0;
        prev.team_count++;
      }

      prev.arr_team[doc.team_id]++;

      prev.order_count++; 
      if(doc.total_amount)
         prev.total_amount += doc.total_amount 

      return retVal;
    }

最终确定：

function(out) {
      out.avg_team_order_amount = out.total_amount/out.team_count;
    }