javascript - 在 MongoDb 中使用 mapReduce 获取文档(行)计数

Question

我讨厌重新发布这些东西，但我觉得我输入的语法与我查找的大多数问题完全相同。我试图简单地计算出价格大于 9000 的行数。有人可以告诉我我做错了什么吗？

var map1 = function(){
    if(this.price > 9000) {
        emit(this._id, {count: 1});
    }
};

var red1 = function(keyId, values){
    var count = 0;
    values.forEach(function(v) {
            count +=v['count'];
            });

    return{count: count};
}

db.plots.mapReduce(map1, red1, {out: "query1"})

我的结果是这样的......

> db.query1.find()
{ "_id" : ObjectId("5170609afa9e8646fc906815"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906816"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90681c"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906834"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90683e"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906846"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90684b"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90684e"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906851"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90685a"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906861"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906864"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906879"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906882"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906883"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90688b"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90688c"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906891"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc906894"), "value" : { "count" : 1 } }
{ "_id" : ObjectId("5170609afa9e8646fc90689a"), "value" : { "count" : 1 } }

我想要的是只取回一个号码。

Answer 1

您做错了几件事 - 您为每个文档发出一个唯一的键:由于reduce将所有具有相同键的文档组合在一起，因此您没有得到聚合，您还将每个值与9000进行比较，而不是使用查询选项来映射/减少。

我不确定你为什么使用map/reduce - 这对于聚合框架来说非常简单:

db.plots.aggregate([ {$match:{price:{$gt:9000}}}, 
                     {$group:{_id:null,count:{$sum:1}}}
] );

如果您有某种原因使用 MapReduce 来执行此操作，我建议您执行以下操作:

map = function() { emit(1, 1); }
reduce = function( key, values ) {
    var count = 0;
    values.forEach(function(v) {
            count +=v;
    });

    return count;
}

db.plots.mapReduce(map, reduce, {out: "query1", query:{price:{$gt:9000}}});