mongoengine 中高級用戶執行聚合函數等

在mongoengine中執行pymongo做高級查詢事例

用到分組、查詢人數、降uid push到列表中

 

    new_user_data = {}
    pipeline = [
        {'$match': {'date': {'$gte': "2020-04-01", '$lte': "2020-04-29"}, "day_age": 0}},
        {'$project': {"date": 1, "uid": 1}},
        {"$group": {"_id": "$date", "count": {"$sum": 1}, "uid_list": {"$push": "$uid"}}}
    ]

    # device_id 列表
    userdaystat = UserDayStat.objects().aggregate(*pipeline)
    for user in userdaystat:
        new_user_data[user["_id"]] = user
    print(new_user_data)

    # lc_user_data =  {'2020-04-16': {'_id': '2020-04-16', 'count': 15}, '2020-04-18': {'_id': '2020-04-18', 'count': 8}}
    lc_user_data = {}
    pipeline = [
        {'$match': {'date': {'$gte': "2020-04-01", '$lte': "2020-04-29"}, "uid": {"$in": ['188287', '176525', '131676',
                                                                                          '112097', '175908', '145366',
                                                                                          '157408', '175846', '168210',
                                                                                          '183352', '178233', '115055',
                                                                                          '159782', '116119',
                                                                                          '127276']}}},
        {'$project': {"date": 1}},
        {"$group": {"_id": "$date", "count": {"$sum": 1}}}
    ]

    lc_user_data = UserDayStat.objects().aggregate(*pipeline)
    for user in userdaystat:
        lc_user_data[user["_id"]] = user
    print(lc_user_data)