1

我有一个 MongoDB 集合，其中包含带有 id 和时间戳的历史数据。

我想从集合中删除早于特定时间戳的数据。但是对于每个 id，至少一个文档（最新的）必须保留在集合中。

假设我的收藏中有以下文件......

{"id" : "11", "timestamp" : ISODate("2011-09-09T10:27:34.785Z")} //1
{"id" : "11", "timestamp" : ISODate("2011-09-08T10:27:34.785Z")} //2

{"id" : "22", "timestamp" : ISODate("2011-09-05T10:27:34.785Z")} //3
{"id" : "22", "timestamp" : ISODate("2011-09-01T10:27:34.785Z")} //4

...并且我想删除时间戳早于 2011-09-07 的文档，那么不应删除 1 和 2，因为它们较新。4 应该被删除，因为它更旧，但 3 不应该被删除（尽管它更旧），因为每个 id 至少有一个文档应该保留在集合中。

有谁知道我如何用 casbah 和/或在 mongo 控制台上做到这一点？

问候， 克里斯蒂安

4

1 回答 1

1

我可以想到几种方法。首先，试试这个：

var cutoff = new ISODate("2011-09-07T00:00:00.000Z");
db.testdata.find().forEach(function(data) {
    if (data.timestamp.valueOf() < cutoff.valueOf()) {
        // A candidate for deletion
        if (db.testdata.find({"id": data.id, "timestamp": { $gt: data.timestamp }}).count() > 0) {
            db.testdata.remove({"_id" : data._id});
         }
    }
});

这可以完成您想要的工作。或者您也可以使用 MapReduce 作业来执行此操作。将此加载到文本文件中：

var map = function() {
    emit(this.id, {
        ref: this._id,
        timestamp: this.timestamp
    });
};


var reduce = function(key, values) {
    var cutoff = new ISODate("2011-09-07T00:00:00.000Z");
    var newest = null;
    var ref = null;
    var i;
    for (i = 0; i < values.length; ++i) {
        if (values[i].timestamp.valueOf() < cutoff.valueOf()) {
            // falls into the delete range
            if (ref == null) {
                ref = values[i].ref;
                newest = values[i].timestamp;
            } else if (values[i].timestamp.valueOf() > newest.valueOf()) {
                // This one is newer than the one we are currently saving.
                // delete ref
                db.testdata.remove({_id : ref});
                ref = values[i].ref;
                newest = values[i].timestamp;
            } else {
                // This one is older
                // delete values[i].ref
                db.testdata.remove({_id : values[i].ref});
            }
        } else if (ref == null) {
            ref = values[i].ref;
            newest = values[i].timestamp;
        }
    }
    return { ref: ref, timestamp: newest };
};

将上述文件加载到 shell 中：load("file.js");

然后运行它：db.testdata.mapReduce(map, reduce, {out: "results"});

然后删除 mapReduce 输出：db.results.drop();

于 2011-09-14T19:51:25.127 回答