通过获取字段的最新值进行PyMongo聚合

Question

我想对我的文档进行分组，对于某些字段，取具有最近时间戳的记录的值(即最近插入/更新的值)。在下面的示例中，我希望按用户ID和电话进行分组，并获取该组中具有最近时间戳的记录的电子邮件。我的初始策略是按时间戳降序排序，并取聚合的第一个值，如下所示：

import pymongo
...
pipeline = [
        {
            "$sort": {"timestamp": -1 }
        },
        { "$group": {
            "_id": {
                    "userId": "$userId",
                    "userPhone": "$userPhone",
                    "userEmail": { "$first" : "$userEmail"},
                    "count": {"$sum": 1}
            }
        }
    ]

然而，我遇到了以下错误：

pymongo.errors.OperationFailure: Unrecognized expression '$first'

有没有适用于pymongo的等效的$first函数？

Answer 1

您的管道语法不正确。累加器在自己的字段上运行。

就像这样

pipeline = [ 
    { "$sort": {"timestamp": -1 } }, 
    { "$group": { "_id": { "userId": "$userId", "userPhone": "$userPhone" }, "userEmail": { "$first" : "$userEmail"}, "count": {"$sum": 1} } } 
]