使用 mongo 和流星获取特定值的前 50 条记录

Question

在我的流星项目中，我有一个排行榜，它在图表上显示每个级别的玩家，分布在游戏中的每个级别。为简单起见，假设有 1-100 级。目前，为了避免流星过载，我只是告诉服务器将每条新的记录发送给我两周前，但这对于准确的排行榜来说是不够的。

我要做的是显示代表每个级别的 50 条记录。因此，如果第 1 级有 100 条记录，第 2 级有 85 条记录，第 3 级有 65 条记录，第 4 级有 45 条记录，我想显示每个级别的 最新 50 条记录，所以我将分别有 [50, 50, 50, 45] 条记录。

数据看起来像这样：

{
    snapshotDate: new Date(),
    level: 1,
    hp: 5000,
    str: 100
}

我认为这需要一些 mongodb 聚合，但我无法完全弄清楚如何在一个查询中执行此操作。但是，将其分成两部分是微不足道的 - 选择所有记录，按级别分组，按日期对每个级别进行排序，然后从每个级别中获取最后 50 条记录。但是，如果可以的话，我宁愿在一次手术中完成。目前可以做这样的事情吗？

Answer 1

目前无法在聚合管道中获取组的n 顶部记录。对此有一个未解决的未解决问题：https://jira.mongodb.org/browse/SERVER-9377。

有两种解决方案：

• 保持您现在的文档结构并进行汇总，但是， 在客户端获取 n 顶部记录并切掉每个组的剩余记录。

代码：

var top_records = [];

db.collection.aggregate([
// The sort operation needs to come before the $group,
// because once the records are grouped by level, 
// there exists only one document per group.
{$sort:{"snapshotDate":-1}},
// Maintain all the records in an array in sorted order. 
{$group:{"_id":"$level","recs":{$push:"$$ROOT"}}},
],{allowDiskUse: true}).forEach(function(level){
     level.recs.splice(50);   //Keep only the top 50 records.
     top_records.push(level);
})

请记住，这会加载每个 level 的所有文档并删除客户端中不需要的记录。

• 改变您的文档结构以完成您真正需要的工作。如果 你只需要顶部的 n 记录，始终保持排序 根文档中的顺序。这是使用sorted capped array 完成的。

您的文档将如下所示：

{
 level:1,
 records:[{snapshotDate:2,hp:5000,str:100},
          {snapshotDate:1,hp:5001,str:101}]
}

其中，records 是一个大小为 n 的封顶数组，并且始终包含按其snapshotDate 降序排列的子文档。

为了使records 数组以这种方式工作，当我们需要为任何level 插入文档时，我们总是执行更新操作。

db.collection.update({"level":1},
            {$push:{
                    recs:{
                          $each:[{snapshotDate:1,hp:5000,str:100},
                                 {snapshotDate:2,hp:5001,str:101}],
                          $sort:{"snapshotDate":-1},
                          $slice:50 //Always trim the array size to 50.
                         }
            }},{upsert:true})

这样做的目的是始终将records 数组的大小保持为50，并且每当在level 处插入新的子文档时始终对记录进行排序。

一个简单的查找，db.collection.find({"level":{$in:[1,2,..]}})，将按顺序为您提供前 50 条记录，每个选定的level。