$lastN
정의
버전 5.2에 추가되었습니다.
$lastN
집계 축적자 또는 배열 연산자로 사용할 수 있습니다. 애그리게이션 축적자로서 그룹 내 마지막 n
개 요소의 애그리게이션입니다. 배열 연산자로서 배열의 끝에서 지정된 수의 요소를 반환합니다.
집계 누산기
$lasttN
을(를) 애그리게이션 축적자로 사용하는 경우 반환된 요소는 지정된 정렬 순서로 정렬되어 있는 경우에만 의미가 있습니다. 그룹에 n
개 미만의 요소가 포함된 경우 $lastN
는 그룹의 모든 요소를 반환합니다.
구문
{ $lastN: { input: <expression>, n: <expression> } }
input
마지막n
을 취할 문서의 필드를 지정합니다. 입력은 모든 표현식이 가능합니다.n
$group
에 대한_id
값에 의존하거나 상수인 양의 정수 표현식 이어야 합니다. 자세한 내용은 그룹 키 예시 를 참조하세요.
행동
Null 및 누락된 값
$lastN
null 값을 필터링하지 않습니다.$lastN
누락된 값을 null로 변환합니다.
그룹에서 마지막 5개의 문서를 반환하는 다음 애그리게이션을 가정해 보겠습니다.
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", lastFiveScores: { $lastN: { input: "$score", n: 5 } } } } ] )
이 예시에서는
$documents
플레이어 점수가 포함된 리터럴 문서를 생성합니다.$group
은gameId
기준으로 문서를 그룹화합니다. 이 예시에는gameId
가 단 하나(G1
)만 있습니다.PlayerD
점수가 누락되었고PlayerE
에 nullscore
가 있습니다. 이 값은 모두 null로 간주됩니다.lastFiveScores
필드는input : "$score"
을 사용하여 지정되고 배열로 반환됩니다.정렬 기준이 없으므로 마지막 5개의
score
필드가 반환됩니다.
[ { _id: "G1", lastFiveScores: [ 1, 2, 3, null, null ] } ]
와 의 비교 $lastN
$bottomN
$lastN
축적자와 $bottomN
축적자는 모두 비슷한 결과를 얻을 수 있습니다.
일반적으로 다음과 같습니다.
$group
에 들어오는 문서가 이미 주문된 경우$lastN
을 사용해야 합니다.하단
n
요소를 정렬하고 선택하는 경우$bottomN
를 사용하여 하나의 축적자로 두 작업을 모두 수행할 수 있습니다.$lastN
는 애그리게이션 표현식으로 사용할 수 있지만$bottomN
은 사용할 수 없습니다.
제한 사항
창 함수 및 집계 표현식 지원
$lastN
은(는) 애그리게이션 표현식으로 지원됩니다.
$lastN
은 window operator
로 지원됩니다.
예시
다음 문서가 포함된 gamescores
collection을 생각해 보세요.
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 } ])
단일 게임의 마지막 3명의 플레이어 점수 찾기
$lastN
축적자를 사용하여 단일 게임의 최근 3개 점수를 찾을 수 있습니다.
db.gamescores.aggregate( [ { $match : { gameId : "G1" } }, { $group: { _id: "$gameId", lastThreeScores: { $lastN: { input: ["$playerId", "$score"], n:3 } } } } ] )
예시 파이프라인:
$match
를 사용하여 단일gameId
결과를 필터링합니다. 이 경우에는G1
입니다.$group
을 사용하여gameId
를 기준으로 결과를 그룹화합니다. 이 경우에는G1
입니다.$lastN
에서output : ["$playerId"," $score"]
로 출력되는 필드를 지정합니다.$lastN
을 사용하여n : 3
가 있는G1
게임에 대한 마지막 세 문서를 반환합니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: "G1", lastThreeScores: [ [ "PlayerB", 33 ], [ "PlayerC", 99 ], [ "PlayerD", 1 ] ] } ]
여러 게임에서 마지막 3명의 플레이어 점수 찾기
$lastN
축적자를 사용하여 각 게임에서 마지막 n
입력 필드를 찾을 수 있습니다.
db.gamescores.aggregate( [ { $group: { _id: "$gameId", playerId: { $lastN: { input: [ "$playerId","$score" ], n: 3 } } } } ] )
예시 파이프라인:
$group
을 사용하여gameId
를 기준으로 결과를 그룹화합니다.$lastN
을 사용하여n: 3
가 포함된 각 게임에 대한 마지막 세 개의 문서를 반환합니다.input : ["$playerId", "$score"]
을 사용하여$lastN
에 입력되는 필드를 지정합니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: 'G2', playerId: [ [ 'PlayerB', 14 ], [ 'PlayerC', 66 ], [ 'PlayerD', 80 ] ] }, { _id: 'G1', playerId: [ [ 'PlayerB', 33 ], [ 'PlayerC', 99 ], [ 'PlayerD', 1 ] ] } ]
와 함께 사용 $sort
$lastN
파이프라인의 초기 단계에서 $sort
단계를 사용하면 $lastN
축적자의 결과에 영향을 미칠 수 있습니다.
이 예시에서는
{$sort : { score : -1 } }
가장 높은 점수를 각 그룹 뒤쪽으로 정렬합니다.lastN
각 그룹 뒤에서 가장 낮은 점수 3개를 반환합니다.
db.gamescores.aggregate( [ { $sort : { score : -1 } }, { $group: { _id: "$gameId", playerId: { $lastN: { input: [ "$playerId","$score" ], n: 3 } } } } ] )
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: 'G2', playerId: [ [ 'PlayerC', 66 ], [ 'PlayerB', 14 ], [ 'PlayerA', 10 ] ] }, { _id: 'G1', playerId: [ [ 'PlayerB', 33 ], [ 'PlayerA', 31 ], [ 'PlayerD', 1 ] ] } ]
의 그룹 키를 기반으로 계산 n
$group
n
의 값을 동적으로 할당할 수도 있습니다. 이 예제에서는 $cond
표현식이 gameId
필드에 사용됩니다.
db.gamescores.aggregate([ { $group: { _id: {"gameId": "$gameId"}, gamescores: { $lastN: { input: "$score", n: { $cond: { if: {$eq: ["$gameId","G2"] }, then: 1, else: 3 } } } } } } ] )
예시 파이프라인:
$group
을 사용하여gameId
를 기준으로 결과를 그룹화합니다.input : "$score"
으로$lastN
에 입력하는 필드를 지정합니다.gameId
가G2
이면n
는 1이고, 그렇지 않으면n
는 3입니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: { gameId: "G1" }, gamescores: [ 33, 99, 1 ] }, { _id: { gameId: "G2" }, gamescores: [ 80 ] } ]
$lastN
애그리게이션 표현식으로 사용
$lastN
를 애그리게이션 표현식으로 사용할 수도 있습니다.
이 예시에서는
$documents
값 배열을 포함하는 리터럴 문서를 만듭니다.$project
$lastN
의 출력값을 반환하는 데 사용됩니다._id
_id : 0
과 함께 출력에서 생략됩니다.$lastN
[10, 20, 30, 40]
의 입력 배열을 사용합니다.배열의 마지막 세 요소는 입력 문서에 대해 반환됩니다.
db.aggregate( [ { $documents: [ { array: [10, 20, 30, 40] } ] }, { $project: { lastThreeElements:{ $lastN: { input: "$array", n: 3 } } } } ] )
이 연산은 다음과 같은 결과를 반환합니다.
[ { lastThreeElements: [ 20, 30, 40 ] } ]
배열 연산자
구문
$lastN
의 구문은 다음과 같습니다:
{ $lastN: { n: <expression>, input: <expression> } }
행동
예시
컬렉션 games
에는 다음 문서가 있습니다.
db.games.insertMany([ { "playerId" : 1, "score" : [ 1, 2, 3 ] }, { "playerId" : 2, "score" : [ 12, 90, 7, 89, 8 ] }, { "playerId" : 3, "score" : [ null ] }, { "playerId" : 4, "score" : [ ] }, { "playerId" : 5, "score" : [ 1293, null, 3489, 9 ]}, { "playerId" : 6, "score" : [ "12.1", 2, NumberLong("2090845886852"), 23 ]} ])
다음 예시 에서는 $lastN
연산자 를 사용하여 각 플레이어의 최근 점수 3개를 조회 합니다. 점수는$addFields
에서 만든 새 필드 lastScores
에 반환됩니다
db.games.aggregate([ { $addFields: { lastScores: { $lastN: { n: 3, input: "$score" } } } } ])
이 연산은 다음과 같은 결과를 반환합니다.
[{ "playerId": 1, "score": [ 1, 2, 3 ], "lastScores": [ 1, 2, 3 ] }, { "playerId": 2, "score": [ 12, 90, 7, 89, 8 ], "lastScores": [ 7, 89, 8 ] }, { "playerId": 3, "score": [ null ], "lastScores": [ null ] }, { "playerId": 4, "score": [ ], "lastScores": [ ] }, { "playerId": 5, "score": [ 1293, null, 3489, 9 ], "lastScores": [ null, 3489, 9 ] }, { "playerId": 6, "score": [ "12.1", 2, NumberLong("2090845886852"), 23 ], "lastScores": [ 2, NumberLong("2090845886852"), 23 ] }]