mongo pipeline 的应用

• '$match' 对应WHERE子句
  当数据表中address字段为一个列表时，如['a' , 'b' , 'c']， 想要匹配其中的第二个值'b', pipeline写成� {'$match': {'address': 'b' }} 也能达到预期效果
• '$group' 对应GROUP BY子句
• pipeline 中定义的筛选条件是顺序执行的，如果调换{'$sort'} 跟 {'$limit'} 的位置，就会发现结果不对了

pipeline = [
        {'$match': {'address': {'$all': [areas[0]]}}},
        {'$group': {'_id': {'$slice': ['$category', 0, 1]}, 'counts': {'$sum': 1}}},
        {'$sort': {'counts': -1}},
        {'$limit': 3}
    ]

Source code

# 由于数据太少了，去掉了发贴时间的筛选条件
def gen_data():
    pipeline = [
        {'$match': {'address': {'$all': [areas[0]]}}},
        {'$group': {'_id': {'$slice': ['$category', 0, 1]}, 'counts': {'$sum': 1}}},
        {'$sort': {'counts': -1}},
        {'$limit': 3}
    ]
    for i in tinfo.aggregate(pipeline):
        item = {
                'name': i['_id'][0],
                'data': [i['counts']],
                'type': 'column'
            }
        yield item

运行结果

Screen Shot 2016-07-10 at 9.12.26 AM.png