我需要为每个用户获取集合中的最新文档(这里是通知)并删除另一个。假设我有这样的数据:

[
    { user: 1, time: ISODate("Mon, 14 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 1, time: ISODate("Tue, 15 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 1, time: ISODate("Fri, 23 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Tue, 27 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Wed, 28 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Wed, 28 Sep 2015 07:33:16 +0000"), msg: "message" }
]

例如，我想获取最后 2 个通知并删除另一个，那么 user 1 的结果应该是:

[
    { user: 1, time: ISODate("Tue, 15 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 1, time: ISODate("Fri, 23 Sep 2015 06:22:36 +0000"), msg: "message" }
]

数据会是这样的:

[
    { user: 1, time: ISODate("Tue, 15 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 1, time: ISODate("Fri, 23 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Tue, 27 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Wed, 28 Sep 2015 06:22:36 +0000"), msg: "message" },
    { user: 2, time: ISODate("Wed, 28 Sep 2015 07:33:16 +0000"), msg: "message" }
]

和属于用户 1 的其他记录将被删除。 那么这样做的有效方法是什么？

最佳答案

我想你的文档应该是这样的:

{ "_id" : ObjectId("562b38f9d6995d3311d9ddce"), "user" : 1, "time" : ISODate("2015-09-14T06:22:36Z"), "msg" : "message" }
{ "_id" : ObjectId("562b38f9d6995d3311d9ddcf"), "user" : 1, "time" : ISODate("2015-09-15T06:22:36Z"), "msg" : "message" }
{ "_id" : ObjectId("562b38f9d6995d3311d9ddd2"), "user" : 2, "time" : ISODate("2015-09-28T06:22:36Z"), "msg" : "message" }
{ "_id" : ObjectId("562b38f9d6995d3311d9ddd3"), "user" : 2, "time" : ISODate("2015-09-28T07:33:16Z"), "msg" : "message" }

来自 MongoDB 3.2你可以使用$slice运算符只为每个用户获取最后两个文档

var bulkOp = db.collection.initializeOrderedBulkOp();
var count = 0;
db.collection.aggregate([ 
    { "$sort": { "user": 1, "time": -1 }}, 
    { "$group": { "_id": "$user", "times": { "$push": "$time" } }}, 
    { "$project": { 
        "times": { 
            "$slice": [ "$times", 2 ]
        }
     }}
]).forEach(function(doc) {
    bulkOp.find({ 
        "user": doc._id, 
        "time": { "$nin": doc.times }
    }).remove();
    count++;
    if(count % 100 === 0) {
        //Execute per 100 operations and re-init 
        bulkOp.execute();
        bulkOp = db.collection.initializeOrderedBulkOp();
    }
})

// Clean up queues
if(count > 0) {
    bulkOp.execute();
}

在 MongoDB 3.2 之前，您需要 $group您的文档由 user 然后使用 $push返回 times 数组的运算符。从那时起，您将需要使用 .forEach 遍历聚合结果。循环然后先返回最后两次 sort在 reverse 中输入您的 times 数组订购和使用 .slice方法。然后您可以使用 "bulk" 删除您的文档操作以获得最大效率。当然是 $nin运算符可让您过滤掉旧文档。

var bulkOp = db.collection.initializeOrderedBulkOp();
var count = 0;
db.collection.aggregate([
    { "$group": {
        "_id": "$user", 
        "times": { "$push": "$time" } 
    } }
]).forEach(function(doc) { 
    var times = doc.times.sort(function(t1, t2) { 
        return t1 < t2 ? -1 :  (t1 > t2 ? 1 : 0); 
    }).reverse().slice(-2);
    bulkOp.find({ 
        "user": doc._id, 
        "time": { "$nin": times }
    }).remove(); 
    count++; 
    if(count % 100 === 0) {  
        //Execute per 100 operations and re-init   
        bulkOp.execute();     
        bulkOp = db.collection.initializeOrderedBulkOp(); 
    } 
})

// Clean up queues
if(count > 0) { 
    bulkOp.execute(); 
}

关于mongodb - 如何获取集合中的最新文档并删除其他，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33314240/