On this page本页内容
$firstN
New in version 5.2.在版本5.2中新增。
Returns an aggregation of the first 返回组中前n
elements within a group. n
个元素的聚合。The elements returned are meaningful only if in a specified sort order. 只有按指定的排序顺序返回的元素才有意义。If the group contains fewer than 如果组包含的元素少于n
elements, $firstN
returns all elements in the group.n
个,$firstN
将返回组中的所有元素。
{ $firstN: { input: <expression>, n: <expression> } }
input
n
of. n
的字段。n
_id
value for $group
. $group
的_id
值。Null
和缺少值$firstN
$firstN
null
。Consider the following aggregation that returns the first five documents from a group:考虑以下聚合,该聚合返回组中的前五个文档:
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", firstFiveScores: { $firstN: { input: "$score", n: 5 } } } } ] )
In this example:在此示例中:
$documents
$group
gameId
. gameId
对文档进行分组。gameId
, G1
.gameId
,G1
。PlayerD
PlayerE
has a null score
. PlayerE
的score
为null
。null
。firstFiveScores
field is specified using input : "$score"
and returned as an array.firstFiveScores
字段是使用输入input : "$score"
指定的,并作为数组返回。score
fields are returned.score
字段。[ { _id: 'G1', firstFiveScores: [ 1, 2, 3, null, null ] } ]
$firstN
and $topN
Accumulators$firstN
和$topN
累加器的比较Both $firstN
and $topN
accumulators can accomplish similar results.$firstN
和$topN
累加器都可以实现类似的结果。
In general:一般来说:
$group
are already ordered, you should use $firstN
.$group
的文档已经排序,则应使用$firstN
。n
elements then you can use $topN
to accomplish both tasks with one accumulator.n
个元素,那么可以使用$topN
用一个累加器完成这两个任务。$firstN
$topN
cannot.$topN
不能。$firstN
is supported as an aggregation expression.可以用作聚合表达式。
For details on aggregation expression usage see Using $firstN as an Aggregation Expression.有关聚合表达式用法的详细信息,请参阅使用$firstN
作为聚合表达式。
$firstN
is supported as a 支持作为窗口运算符。window operator
.
Aggregation pipelines which call 调用$firstN
are subject to the 100 MB limit. $firstN
的聚合管道受100MB限制。If this limit is exceeded for an individual group, the aggregation fails with an error.如果单个组超过了此限制,则聚合将失败并返回错误。
Consider a 考虑一个包含以下文档的gamescores
collection with the following documents: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 } ])
You can use the 您可以使用$firstN
accumulator to find the first three scores in a single game.$firstN
累加器查找单个游戏中的前三个分数。
db.gamescores.aggregate( [ { $match : { gameId : "G1" } }, { $group: { _id: "$gameId", firstThreeScores: { $firstN: { input: ["$playerId", "$score"], n:3 } } } } ] )
The example pipeline:示例管道:
$match
to filter the results on a single gameId
. $match
筛选单个gameId
上的结果。G1
.G1
。$group
to group the results by gameId
. $group
按gameId
对结果进行分组。G1
.G1
。$firstN
with input : ["$playerId"," $score"]
.input : ["$playerId"," $score"]
的$firstN
的输入。$firstN
to return the first three documents for the G1
game with n : 3
.$firstN
返回带有n:3
的G1
游戏的前三个文档。The operation returns the following results:该操作返回以下结果:
[ { _id: 'G1', firstThreeScores: [ [ 'PlayerA', 31 ], [ 'PlayerB', 33 ], [ 'PlayerC', 99 ] ] } ]
You can use the 您可以使用$firstN
accumulator to find the first n
input fields in each game.$firstN
累加器查找每个游戏中的前n
个输入字段。
db.gamescores.aggregate( [ { $group: { _id: "$gameId", playerId: { $firstN: { input: [ "$playerId","$score" ], n: 3 } } } } ] )
The example pipeline:示例管道:
$group
to group the results by gameId
.$group
按gameId
对结果进行分组。$firstN
to return the first three documents for each game with n: 3
.$firstN
返回n:3
的每个游戏的前三个文档。$firstN
with input : ["$playerId", "$score"]
.input : ["$playerId", "$score"]
的$firstN
的输入。The operation returns the following results:该操作返回以下结果:
[ { _id: 'G1', playerId: [ [ 'PlayerA', 31 ], [ 'PlayerB', 33 ], [ 'PlayerC', 99 ] ] }, { _id: 'G2', playerId: [ [ 'PlayerA', 10 ], [ 'PlayerB', 14 ], [ 'PlayerC', 66 ] ] } ]
$sort
With $firstN
$sort
配合$firstN
Using a 在管道的前面使用$sort
stage earlier in the pipeline can influence the results of the $firstN
accumulator.$sort
阶段可能会影响$firstN
累加器的结果。
In this example:在此示例中:
{$sort : { score : -1 } }
firstN
db.gamescores.aggregate( [ { $sort : { score : -1 } }, { $group: { _id: "$gameId", playerId: { $firstN: { input: [ "$playerId","$score" ], n: 3 } } } } ] )
The operation returns the following results:该操作返回以下结果:
[ { _id: 'G2', playerId: [ [ 'PlayerD', 80 ], [ 'PlayerC', 66 ], [ 'PlayerB', 14 ] ] }, { _id: 'G1', playerId: [ [ 'PlayerC', 99 ], [ 'PlayerB', 33 ], [ 'PlayerA', 31 ] ] } ]
n
Based on the Group Key for $group
$group
的组键计算n
You can also assign the value of 还可以动态指定n
dynamically. n
的值。In this example, the 在本例中,$cond
expression is used on the gameId
field.$cond
表达式用于gameId
字段。
db.gamescores.aggregate([ { $group: { _id: {"gameId": "$gameId"}, gamescores: { $firstN: { input: "$score", n: { $cond: { if: {$eq: ["$gameId","G2"] }, then: 1, else: 3 } } } } } } ] )
The example pipeline:示例管道:
$group
to group the results by gameId
.$group
按gameId
对结果进行分组。$firstN
with input : "$score"
.input : "$score"
的$firstN
输入。gameId
is G2
then n
is 1, otherwise n
is 3.gameId
为G2
,则n
为1
,否则n
为3
。The operation returns the following results:该操作返回以下结果:
[ { _id: { gameId: 'G1' }, gamescores: [ 31, 33, 99 ] }, { _id: { gameId: 'G2' }, gamescores: [ 10 ] } ]
$firstN
as an Aggregation Expression$firstN
作为聚合表达式You can also use 还可以使用$firstN
as an aggregation expression.$firstN
作为聚合表达式。
In this example:在此示例中:
$documents
$project
$firstN
.$firstN
的输出。_id
_id : 0
._id
为0
的输出中省略。$firstN
[10, 20, 30, 40]
.[10, 20, 30, 40]
。db.aggregate( [ { $documents: [ { array: [10, 20, 30, 40] } ] }, { $project: { firstThreeElements:{ $firstN: { input: "$array", n: 3 } } } } ] )
The operation returns the following results:该操作返回以下结果:
[ { firstThreeElements: [ 10, 20, 30 ] } ]