mongodb中使用mapreduce进行分组统计

最近在统计某一个时间段的url去重数，由于数据量巨大导致报错，提示：

我们提供的服务有：成都网站制作、成都做网站、微信公众号开发、网站优化、网站认证、青铜峡ssl等。为上1000家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务，是有科学管理、有技术的青铜峡网站制作公司

distinct failed: {
"errmsg" : "exception: distinct too big, 16mb cap",
"code" : 17217,
"ok" : 0
} at src/mongo/shell/collection.js:1108

最终通过mapreduce来解决如下：

//定义map函数
map=function(){
    emit(this.url,{"count":1});
}

//定义reduce函数
reduce=function(key,values){
    var total=0;
    for(var i=0; i < values.length; i++){
        total+=values[i].count;
    }
    return {count:total}
}

//执行mapreduce函数,其中out的值是存储执行结果的集合
db.runCommand({"mapreduce":"visit","map":map,"reduce":reduce,"query":{"vtime":{"$gte":1412611200,"$lte":1413907119}},"out":"test.tmp"});

关于mapreduce的选项解释如下：

"out":{replace:"collection name"} -- mapreduce输出结果会替换掉原来的collection,collection不存在则创建
"out":{merge:"collection name"} -- 将新老数据进行合并，新的替换旧的，没有的添加进去
"out":{reduce:"collection name"}-- 存在老数据时，在原来的基础上加新的数据（即new value=old value+mapreduce value）
"out":{inline:1} -- 不会创建collection，结果保存在内存里面，只限于结果小于16MB的情况

当前标题：mongodb中使用mapreduce进行分组统计
文章网址：https://www.cdcxhl.com/article16/iiesgg.html

成都网站建设公司_创新互联，为您提供网站设计、网站策划、网站设计公司、商城网站、静态网站、电子商务

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联