为集合中的所有键运行 map reduce - mongodb

Question

我在 mongodb 中使用 map reduce 来找出像这样的客户的订单数量

db.order.mapReduce(
    function() {
        emit (this.customer,{count:1})
    },
    function(key,values){
        var sum =0 ; 
        values.forEach(
            function(value) {
                sum+=value['count'];
            }
        ); 
        return {count:sum};
    },
    {
         query:{customer:ObjectId("552623e7e4b0cade517f9714")},
         out:"order_total"
    }).find()

这给了我这样的输出

{ "_id" : ObjectId("552623e7e4b0cade517f9714"), "value" : { "count" : 13 } }

目前它正在为一个关键的客户工作。现在我希望它为订单集合中的所有客户运行这个 map reduce 查询，并像这个单一输出一样为所有客户输出结果。有什么方法可以让所有客户按顺序进行操作吗？

Answer 1

对这个简单的任务使用 map/reduce 有点像使用（相对较慢的）大锤来破解难题。 aggregation framework 基本上是为这种简单的聚合而发明的（并且可以为您做更多事情！）：

db.order.aggregate([
    { "$group":{ "_id":"$customer", "orders":{ "$sum": 1 }}},
    { "$out": "order_total"}
])

根据您的用例，您甚至可以省略 $out 阶段并直接使用结果。

> db.orders.aggregate([{ "$group":{ "_id":"$customer", "orders":{ "$sum": 1 }}}])
{ "_id" : "b", "orders" : 2 }
{ "_id" : "a", "orders" : 3 }

请注意，对于非常大的集合，这很可能不合适，因为它需要一段时间（但它仍然应该比 map/reduce 操作更快）。

对于单个客户的订单数量，可以使用简单的查询，使用cursor.count()方法：

> db.orders.find({ "customer": "a" }).count()
3