$top(聚合累加器)
定义
语法
{ $top: { sortBy: { <field1>: <sort order>, <field2>: <sort order> ... }, output: <expression> } }
字段 | 必要性 | 说明 |
---|---|---|
sortBy | 必需 | 指定结果的顺序,语法类似于 |
输出 | 必需 | 表示组中每个元素的输出,可以是任何表达式。 |
行为
Null 和缺失值
考虑以下聚合,该聚合从一组分数中返回最高分的文档:
$top
不筛选空值。$top
将缺失值转换为空。
db.aggregate( [ { $documents: [ { playerId: "PlayerA", gameId: "G1", score: 1 }, { playerId: "PlayerB", gameId: "G1", score: 2 }, { playerId: "PlayerC", gameId: "G1", score: 3 }, { playerId: "PlayerD", gameId: "G1"}, { playerId: "PlayerE", gameId: "G1", score: null } ] }, { $group: { _id: "$gameId", playerId: { $top: { output: [ "$playerId", "$score" ], sortBy: { "score": 1 } } } } } ] )
在本例中:
$documents
创建包含玩家分数的字面文档。$group
按gameId
对文档进行分组。此示例只有一个gameId
、G1
。PlayerD
分数缺失,且PlayerE
的score
为空。这些值都被视为空值。playerId
和score
字段指定为output : ["$playerId"," $score"]
,并以数组值形式返回。用
sortBy: { "score": 1 }
指定排序顺序。PlayerD
和PlayerE
并列为顶元素。PlayerD
作为顶级score
返回。要对多个空值进行更具确定性的平局决胜行为,请向
sortBy
添加更多字段。
[ { _id: 'G1', playerId: [ 'PlayerD', null ] } ]
限制
窗口函数和聚合表达式支持
$top
不支持作为聚合表达式。
$top
支持作为 window operator
。
内存限制注意事项
调用 $top
的聚合管道受 100 MB 限制。如果单个群组超过此限制,则聚合失败,并显示错误。
示例
请考虑包含以下文档的 gamescores
集合:
db.gamescores.insertMany([ { playerId: "PlayerA", gameId: "G1", score: 31 }, { playerId: "PlayerB", gameId: "G1", score: 33 }, { playerId: "PlayerC", gameId: "G1", score: 99 }, { playerId: "PlayerD", gameId: "G1", score: 1 }, { playerId: "PlayerA", gameId: "G2", score: 10 }, { playerId: "PlayerB", gameId: "G2", score: 14 }, { playerId: "PlayerC", gameId: "G2", score: 66 }, { playerId: "PlayerD", gameId: "G2", score: 80 } ])
查找顶部 Score
您可以使用 $top
累加器查找单个游戏中的最高分。
db.gamescores.aggregate( [ { $match : { gameId : "G1" } }, { $group: { _id: "$gameId", playerId: { $top: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 } } } } } ] )
示例管道:
使用
$match
筛选单个gameId
的结果。在本例中为G1
。使用
$group
按gameId
对结果分组。本例中为G1
。指定
$top
和output : ["$playerId"," $score"]
输出的字段。使用
sortBy: { "score": -1 }
按降序对分数进行排序。使用
$top
返回游戏中的最高分。
操作返回以下结果:
[ { _id: 'G1', playerId: [ 'PlayerC', 99 ] } ]
Score
查找多款游戏中排名靠前的
你可以使用 $top
累加器查找每场游戏中的最高 score
。
db.gamescores.aggregate( [ { $group: { _id: "$gameId", playerId: { $top: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 } } } } } ] )
示例管道:
使用
$group
按gameId
对结果进行分组。使用
$top
返回每场比赛的最高score
。指定
$top
和output : ["$playerId", "$score"]
输出的字段。使用
sortBy: { "score": -1 }
按降序对分数进行排序。
操作返回以下结果:
[ { _id: 'G2', playerId: [ 'PlayerD', 80 ] }, { _id: 'G1', playerId: [ 'PlayerC', 99 ] } ]