bottomN(집계 누산기)
정의
구문
{ $bottomN: { n: <expression>, sortBy: { <field1>: <sort order>, <field2>: <sort order> ... }, output: <expression> } }
n
그룹 결과 수를 제한하며$group
에 대한 상수 또는_id
값에 의존하는 양의 정수 표현식 이어야 합니다.output
그룹의 각 요소에 대한 출력을 나타내며 모든 표현식이 될 수 있습니다.
행동
Null 및 누락된 값
$bottomN
null 값을 필터링하지 않습니다.$bottomN
누락된 값을 출력에 유지되는 null로 변환합니다.
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: { $bottomN: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 }, n: 3 } } } } ] )
이 예시에서는
$documents
플레이어 점수가 포함된 리터럴 문서를 생성합니다.$group
은gameId
기준으로 문서를 그룹화합니다. 이 예시에는gameId
가 단 하나(G1
)만 있습니다.PlayerD
점수가 누락되었고PlayerE
에 nullscore
가 있습니다. 이 값은 모두 null로 간주됩니다.playerId
및score
필드는output : ["$playerId"," $score"]
로 지정되고 배열 값으로 반환됩니다.sortBy: { "score" : -1 }
때문에 null 값은 반환된playerId
배열의 끝으로 정렬됩니다.
[ { _id: "G1", playerId: [ [ "PlayerA", 1 ], [ "PlayerD", null ], [ "PlayerE", null ] ] } ]
BSON 데이터 유형 정렬 순서
서로 다른 유형을 정렬할 때 BSON 데이터 유형 의 순서를 사용하여 순서를 결정합니다. 예를 들어 값이 문자열과 숫자로 구성된 컬렉션을 생각해 보겠습니다.
오름차순 정렬에서는 문자열 값이 숫자 값 뒤에 정렬됩니다.
내림차순 정렬에서는 문자열 값이 숫자 값보다 먼저 정렬됩니다.
db.aggregate( [ { $documents: [ { playerId: "PlayerA", gameId: "G1", score: 1 }, { playerId: "PlayerB", gameId: "G1", score: "2" }, { playerId: "PlayerC", gameId: "G1", score: "" } ] }, { $group: { _id: "$gameId", playerId: { $bottomN: { output: ["$playerId","$score"], sortBy: {"score": -1}, n: 3 } } } } ] )
이 예시에서는
PlayerA
의 점수는 정수입니다.PlayerB
문자열"2"
점수를 가집니다.PlayerC
빈 문자열 점수가 있습니다.
정렬이 { "score" : -1 }
내림차순으로 이루어지기 때문에 문자열 리터럴 값은 PlayerA
의 숫자 점수보다 먼저 정렬됩니다.
[ { _id: "G1", playerId: [ [ "PlayerB", "2" ], [ "PlayerC", "" ], [ "PlayerA", 1 ] ] } ]
제한 사항
창 함수 및 집계 표현식 지원
$bottomN
집계 표현식으로 지원되지 않습니다.
$bottomN
은 window operator
로 지원됩니다.
메모리 제한 고려 사항
$bottomN
집계 파이프라인 내의 그룹에는 100MB 제한 파이프라인 제한이 적용됩니다. 개별 그룹에 대해 이 제한을 초과하면 오류가 발생하면서 애그리게이션이 실패합니다.
예시
다음 문서가 포함된 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개 찾기 Scores
$bottomN
축적자를 사용하여 단일 게임에서 가장 낮은 점수를 받은 플레이어를 찾을 수 있습니다.
db.gamescores.aggregate( [ { $match : { gameId : "G1" } }, { $group: { _id: "$gameId", playerId: { $bottomN: { output: ["$playerId", "$score"], sortBy: { "score": -1 }, n:3 } } } } ] )
예시 파이프라인:
$match
를 사용하여 단일gameId
결과를 필터링합니다. 이 경우에는G1
입니다.$group
을 사용하여gameId
를 기준으로 결과를 그룹화합니다. 이 경우에는G1
입니다.{ "score": -1 }
기준 정렬을 사용하여 결과를 내림차순으로 정렬합니다.$bottomN
에서output : ["$playerId"," $score"]
로 출력되는 필드를 지정합니다.$bottomN
을 사용하여n : 3
가 있는G1
게임에서 가장 낮은score
를 가진 하위 세 문서를 반환합니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: "G1", playerId: [ [ "PlayerB", 33 ], [ "PlayerA", 31 ], [ "PlayerD", 1 ] ] } ]
이 쿼리와 동일한 SQL:
SELECT T3.GAMEID,T3.PLAYERID,T3.SCORE FROM GAMESCORES AS GS JOIN (SELECT TOP 3 GAMEID,PLAYERID,SCORE FROM GAMESCORES WHERE GAMEID = "G1" ORDER BY SCORE) AS T3 ON GS.GAMEID = T3.GAMEID GROUP BY T3.GAMEID,T3.PLAYERID,T3.SCORE ORDER BY T3.SCORE DESC
여러 게임에서 점수가 가장 낮은 문서 3개 찾기
$bottomN
축적자를 사용하여 각 게임에서 가장 낮은 점수를 받은 플레이어를 찾을 수 있습니다.
db.gamescores.aggregate( [ { $group: { _id: "$gameId", playerId: { $bottomN: { output: [ "$playerId","$score" ], sortBy: { "score": -1 }, n: 3 } } } } ] )
예시 파이프라인:
$group
을 사용하여gameId
를 기준으로 결과를 그룹화합니다.$bottomN
에서output : ["$playerId", "$score"]
로 출력되는 필드를 지정합니다.{ "score": -1 }
기준 정렬을 사용하여 결과를 내림차순으로 정렬합니다.$bottomN
을 사용하여 각 게임에서 가장 낮은score
를 가진 하위 세 문서를n: 3
로 반환합니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: "G1", playerId: [ [ "PlayerB", 33 ], [ "PlayerA", 31 ], [ "PlayerD", 1 ] ] }, { _id: "G2", playerId: [ [ "PlayerC", 66 ], [ "PlayerB", 14 ], [ "PlayerA", 10 ] ] } ]
이 쿼리와 동일한 SQL:
SELECT PLAYERID,GAMEID,SCORE FROM( SELECT ROW_NUMBER() OVER (PARTITION BY GAMEID ORDER BY SCORE DESC) AS GAMERANK, GAMEID,PLAYERID,SCORE FROM GAMESCORES ) AS T WHERE GAMERANK >= 2 ORDER BY GAMEID
의 그룹 키를 기반으로 계산 n
$group
n
의 값을 동적으로 할당할 수도 있습니다. 이 예제에서는 $cond
표현식이 gameId
필드에 사용됩니다.
db.gamescores.aggregate([ { $group: { _id: {"gameId": "$gameId"}, gamescores: { $bottomN: { output: "$score", n: { $cond: { if: {$eq: ["$gameId","G2"] }, then: 1, else: 3 } }, sortBy: { "score": -1 } } } } } ] )
예시 파이프라인:
$group
을 사용하여gameId
을 기준으로 결과를 그룹화합니다.$bottomN
에서output : "$score"
로 출력되는 필드를 지정합니다.gameId
가G2
이면n
는 1이고, 그렇지 않으면n
는 3입니다.{ "score": -1 }
기준 정렬을 사용하여 결과를 내림차순으로 정렬합니다.
이 연산은 다음과 같은 결과를 반환합니다.
[ { _id: { gameId: "G2" }, gamescores: [ 10 ] }, { _id: { gameId: "G1" }, gamescores: [ 33, 31, 1 ] } ]