关于中国马桶十大品牌排名pymongo的聚合函数aggregate的⽤法,⽤于统计
mongodb中collection的数据是这样的
{ "_id" : ObjectId("55d304e44ac0ed5e1ea834a3"), "update_time" : "2015-08-18 18:27:29", "share_pv" : 0, "topic_id" : "205", "share_ip" : 0, "date" : "2015-08-18", "view_ip" : 2, "view_pv" : 117 }
{ "_id" : ObjectId("55d30c924ac0ed5fb70ef57f"), "update_time" : "2015-08-18 20:29:21", "topic_id" : 205, "date" : "2015-08-18", "topic_title" : "⼤叔の店铺", "share_pv" : 0, "share_ip" : 0, "view_ip" : 2, "view_pv" : 235 }
我需要查询按照topic_id来分组的，每个topic_id的share_pv的总和,share_ip的总和,view_ip的总和,view_pv的总和.
conn = pymongo.Connection()
collection = llection_name
#match⽤户筛选，相当于sql语句中的where后⾯的表达式
match = {}
match['date'] = {
'$gte' : '2015-08-21', #⼤于等于2015年8⽉21⽇的
初三数学总复习
'$lte' : '2015-08-23' #⼩于等于2015年8⽉23⽇的
}
#根据什么来分组相当于sql语句中的group by语句
group = {}鬃狮蜥蜴
group['_id'] = "$topic_id" #根据topic_id来分组
group['all_view_ip'] = {
'$sum' : '$$view_ip', #对view_ip字段求和
}
group['all_view_pv'] = {
皮蛋是怎么做出来的'$sum' : '$view_pv', #对view_pv字段求和
}
group['date'] = {'$addToSet':"$date"}, #date字段添加到返回结果⾥⾯去
#对结果进⾏排序
水印怎么弄sort = {油菜种植时间
陆小果'all_view_ip' : 1, #all_view_ip来⾃于上⾯group当中的key,-1和1分别表⽰倒序和升序
}
collection.aggregate([match, group, sort])
