? ? ? 来,我给你们看一段神奇的mongodb的mapreduce操作!
?
?
首先我们执行一段js,用来往mongodb数据库里插入几条记录:
//insert.js
for(var i=0;i<5;i++){
db.RegistRecord.save({"ip":"11.11.11.11","account":"ongyong"});
}
for(var i=0;i<2;i++){
db.RegistRecord.save({"ip":"11.11.11.22","account":"ongyong22"});
}
for(var i=0;i<1;i++){
db.RegistRecord.save({"ip":"11.11.11.33","account":"ongyong33"});
}
?没有问题,随后我们来使用mongodb的mapreduce来进行一个统计,统计同一ip在记录里出现的次数,很简单的mapreduce入门例子,写法如下,不多解释。
//regmp.js
printjson("job start");
var map = function() {
emit(this.ip, {value: 1});
}
var reduce = function(key, values) {
var count = 0;
values.forEach(function(v) {
count += v['value'];
});
return {count: count };
}
var res = db.runCommand({mapreduce:"RegistRecord",map:map, reduce:reduce, out:"log_results"});
printjson("job end")
?然后我们执行这个js脚本。
我们看结果:
/* 0 */
{
"_id" : "11.11.11.11",
"value" : {
"count" : 5.0
}
}
/* 1 */
{
"_id" : "11.11.11.22",
"value" : {
"count" : 2.0
}
}
/* 2 */
{
"_id" : "11.11.11.33",
"value" : {
"value" : 1.0
}
}
?OK,运算结果正确,各ip分别出现了5次,2次,1次。
OK,到这里,如果你认为我就是要为了演示这个东西,那我肯定是来找喷的,哥们儿,这特么一点也不神奇。神奇的事情在下面,我们继续看:
当我们把记录数增加到某一个量级,(如2000)
//insert.js
for(var i=0;i<2000;i++){
db.RegistRecord.save({"ip":"11.11.11.11","account":"ongyong"});
}
for(var i=0;i<2;i++){
db.RegistRecord.save({"ip":"11.11.11.22","account":"ongyong22"});
}
for(var i=0;i<1;i++){
db.RegistRecord.save({"ip":"11.11.11.33","account":"ongyong33"});
}
?然后我们再次执行regmp.js这段代码运行mapreduce,注意,绝对没有任何改动,这时,神奇的事情出现了,看结果:
/* 0 */
{
"_id" : "11.11.11.11",
"value" : {
