mongoDB的mapreduce

mongoDB的map reduce使用 示例： res = db.runCommand({ mapreduce:liveEpgUserVisits, map:function() { emit({provice:this.provice}, {data:[{mac:this.mac}],visit:this.visitNum, userCount:0}); }, reduce:function(key, value) { var ret = {data:[]}

mongoDB的map reduce使用

示例：

res = db.runCommand({
mapreduce:'liveEpgUserVisits',
map:function() {
emit({provice:this.provice}, {"data":[{"mac":this.mac}],visit:this.visitNum, userCount:0});
},
reduce:function(key, value) {
var ret = {data:[]}, visit=0
var userCount=0;
var macs = {};
var sum = 0;
for(var i in value) {
var ia = value[i];
for(var j in ia.data) {
if(!macs[ia.data[j].mac]) {
macs[ia.data[j].mac] = true;
ret.data.push(ia.data[j]);

userCount += 1;

}
}

sum += Number(ia.visit);
}
ret.visit = sum;
ret.userCount = userCount;
return ret;
},
query:{"inputTime":{$gte:ISODate("2014-09-17T14:20:00Z"),$lte:ISODate("2014-09-17T14:30:00Z")}},
finalize:function(key, values){
return [{count:values.data.length},{visit:values.visit},{userCount:values.userCount}];
},
out:'tmp_mo_spcode_consignid_1',
verbose:true
}) 上面的示例， map：key是省份，value是这个省份对应的mac值、访问数量、用户数量。 reduce：获取到每个省份的value，然后进行运算，在将结果返回。通过finalize参数指定输出格式。如果不指定输出格式则会安装map的key和value格式进行输出。

其中db.runCommand包含以下参数：

db.runCommand(
 { mapreduce : ,
   map : ,
   reduce : 
   [, query : ]
   [, sort : ]
   [, limit : ]
   [, out : ]
   [, keeptemp: ]
   [, finalize : ]
   [, scope :