/ /

$topN（アキュムレータ演算子）

定義

$topN

グループ内の上位n要素の集計を、指定のソート順序に従って返します。グループに含まれる要素がn未満の場合、 $topNはグループ内のすべての要素を返します。

注意

$topN のその他の用途

このページでは、アキュムレータとして使用する場合の$topN について説明します。アキュムレータは、入力ドキュメントのグループにわたる集計値を返します。

$topN (window function)また、n を使用することもできます。これは、指定ソート順に従って、特定のウィンドウ内のドキュメントの上位要素を返します。

構文

{
   $topN:
      {
         n: <expression>,
         sortBy: { <field1>: <sort order>, <field2>: <sort order> ... },
         output: <expression>
      }
}

フィールド	タイプ	説明
`n`	式	グループごとに返される結果の最大数を決定します。 `n` は正の整数に評価される必要があります。
`sortBy`	ドキュメント	`$sort`と同様の構文で結果の順序を指定します。パイプライン出力内のドキュメントの順序には影響しません。
`output`	式	グループ内の各要素の出力を指定します。任意の式を指定できます。

動作

NULL および欠損値

$topN は、null 値をフィルタリングで除外しません。
$topN は、出力に保持される欠落値を 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:
            {
               $topN:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": 1 },
                     n: 3
                  }
            }
      }
   }
] )

この例では、次のことが行われます。

$documents は、プレイヤーのスコアを含むリテラルドキュメントを作成します。
$groupはドキュメントをgameIdでグループ化します。この例ではgameId 、 G1は 1 つのみです。
PlayerD はスコアが欠落しており、 PlayerEには null scoreがあります。これらの値は両方とも null と見なされます。
playerIdフィールドとscoreフィールドはoutput : ["$playerId"," $score"]として指定され、配列値として返されます。
sortBy: { "score" : 1 }により、null 値は返されたplayerId配列の前にソートされます。

[
   {
      _id: 'G1',
      playerId: [ [ 'PlayerD', null ], [ 'PlayerE', null ], [ 'PlayerA', 1 ] ]
   }
]

BSON データ型ソート順

異なるタイプをソートする場合、順序を決定するためにBSON データ型の順序が使用されます。例として、値が string と数値で構成されるコレクションを考えてみましょう。

昇順ソートでは、string 値は数値の後にソートされます。
降順ソートでは、string 値が数値の前にソートされます。

db.aggregate( [
   {
      $documents: [
         { playerId: "PlayerA", gameId: "G1", score: 1 },
         { playerId: "PlayerB", gameId: "G1", score: "2" },
         { playerId: "PlayerC", gameId: "G1", score: "" }
      ]
   },
   {
      $group:
         {
            _id: "$gameId",
            playerId: {
               $topN:
               {
                  output: ["$playerId","$score"],
                  sortBy: {"score": -1},
                  n: 3
               }
            }
         }
   }
] )

この例では、次のことが行われます。

PlayerA は整数スコアを持ちます。
PlayerB は string "2"スコアを持ちます。
PlayerC には空のstringスコアがあります。

並べ替えは{ "score" : -1 }の降順であるため、string リテラル値はPlayerAの数値スコアより前にソートされます。

[
   {
      _id: "G1",
      playerId: [ [ "PlayerB", "2" ], [ "PlayerC", "" ], [ "PlayerA", 1 ] ]
   }
]

例

このページの例では、 sample_mflix データセットのデータを使用します。このデータセットを自己管理型MongoDBデプロイにロードする方法の詳細については、「サンプルデータセットをロードする」を参照してください。サンプルデータベースに変更を加えた場合、このページの例を実行するには、データベースを削除して再作成する必要がある場合があります。

1 つのジャンルで最高評価の映画 3 つを見つける

$topNアキュムレータを使用すると、Short ジャンルで最も評価の高い映画を 3 つ見つけることができます。

db.movies.aggregate( [
   {
      $match: {
         genres: "Short",
         "imdb.rating": { $gt: 0 }
      }
   },
   {
      $group: {
         _id: "Short",
         topRatedMovies: {
            $topN: {
               output: [ "$title", "$imdb.rating" ],
               sortBy: { "imdb.rating": -1, title: 1 },
               n: 3
            }
         }
      }
   }
] )

[
  {
    _id: 'Short',
    topRatedMovies: [
      [ 'Rabbit and Deer', 8.7 ],
      [ 'Assume the Position with Mr. Wuhl', 8.6 ],
      [ 'Hole', 8.6 ]
    ]
  }
]

サンプルパイプライン:

$matchShortを使用して、imdb.rating 値を含む映画に入力を制限します。
$groupを使用して、一致した映画を単一のShort グループに配置します。
sortBy: { "imdb.rating": -1, title: 1 } を使用して映画の評価をランク付けし、title をタイブレークとして使用します。
output: [ "$title", "$imdb.rating" ] を使用して $topN によって返されるフィールドを指定します。
$topN を使用して、n: 3 に一致する上位 3 つの映画を返します。

各ジャンルで最高評価の映画を見つける

$topNアキュムレータを使用して、各ジャンルで最も評価の高い映画を見つけることができます。

db.movies.aggregate( [
   {
      $unwind: "$genres"
   },
   {
      $match: {
         "imdb.rating": { $gt: 0 }
      }
   },
   {
      $group: {
         _id: "$genres",
         topRatedMovies: {
            $topN: {
               output: [ "$title", "$imdb.rating" ],
               sortBy: { "imdb.rating": -1, title: 1 },
               n: 3
            }
         }
      }
   },
   {
      $sort: { _id: 1 }
   },
   {
      $limit: 5
   }
] )

[
  {
    _id: 'Action',
    topRatedMovies: [
      [ 'Band of Brothers', 9.6 ],
      [ 'The Real Miyagi', 9.3 ],
      [ 'The Dark Knight', 9 ]
    ]
  },
  {
    _id: 'Adventure',
    topRatedMovies: [
      [ 'Over the Garden Wall', 9.2 ],
      [ 'Love is God', 8.9 ],
      [ 'The Lord of the Rings: The Return of the King', 8.9 ]
    ]
  },
  {
    _id: 'Animation',
    topRatedMovies: [
      [ 'Over the Garden Wall', 9.2 ],
      [ 'Death Note', 9 ],
      [ 'Rabbit and Deer', 8.7 ]
    ]
  },
  {
    _id: 'Biography',
    topRatedMovies: [
      [ 'A Brave Heart: The Lizzie Velasquez Story', 9.4 ],
      [ "Schindler's List", 8.9 ],
      [ 'Shining Night: A Portrait of Composer Morten Lauridsen', 8.8 ]
    ]
  },
  {
    _id: 'Comedy',
    topRatedMovies: [
      [ 'Over the Garden Wall', 9.2 ],
      [ 'Heart of a Dog', 9 ],
      [ 'The Chaos Class Failed the Class', 9 ]
    ]
  }
]

サンプルパイプライン:

$unwindを使用して各映画のgenres 配列を展開します。
$matchimdb.ratingを使用して、値を含むドキュメントのみを保持します。
$group結果をジャンル別にグループ化するには、を使用します。
output: [ "$title", "$imdb.rating" ] を使用して $topN によって返されるフィールドを指定します。
sortBy: { "imdb.rating": -1, title: 1 } を使用して映画の評価をランク付けし、title を決定的なタイブレークとして使用します。
$topN を使用して、n: 3 を持つ各ジャンルの上位 3 つの映画を返します。
最初の 5$sort$limit つのジャンルをアルファベット順に表示するには、とを使用します。

グループキーに基づいて n を動的に設定

nの値は動的に割り当てることができます。次の例では、$cond 式を使用して、コンテンツ評価に基づいてさまざまな数の映画を返します。

db.movies.aggregate( [
   {
      $match: {
         rated: { $in: [ "G", "PG", "PG-13", "R" ] },
         "imdb.rating": { $gt: 0 }
      }
   },
   {
      $group: {
         _id: { rated: "$rated" },
         movies: {
            $topN: {
               output: { title: "$title", rating: "$imdb.rating" },
               n: {
                  $cond: {
                     if: { $eq: [ "$rated", "PG" ] },
                     then: 3,
                     else: 1
                  }
               },
               sortBy: { "imdb.rating": -1 }
            }
         }
      }
   },
   {
      $sort: { "_id.rated": 1 }
   }
] )

[
  {
    _id: { rated: 'G' },
    movies: [ { title: 'Modern Times', rating: 8.6 } ]
  },
  {
    _id: { rated: 'PG' },
    movies: [
      { title: 'Life', rating: 9.2 },
      {
        title: 'Star Wars: Episode V - The Empire Strikes Back',
        rating: 8.8
      },
      { title: 'Andaz Apna Apna', rating: 8.8 }
    ]
  },
  {
    _id: { rated: 'PG-13' },
    movies: [
      {
        title: 'A Brave Heart: The Lizzie Velasquez Story',
        rating: 9.4
      }
    ]
  },
  {
    _id: { rated: 'R' },
    movies: [ { title: 'The Shawshank Redemption', rating: 9.3 } ]
  }
]

サンプルパイプライン:

$matchGを使用して、、PG 、PG-13 、またはR のコンテンツ評価で、imdb.rating 値が含まれる映画のみを保持します。
$groupを使用して、結果を_id: { rated: "$rated" } のコンテンツ評価でグループ化します。
output: { title: "$title", rating: "$imdb.rating" } を使用して $topN によって返されるフィールドを指定します。
コンテンツ評価が PG の場合、n は 3 です。それ以外の場合、n は 1 です。
sortBy: { "imdb.rating": -1 } を使用して、 IMDb スコアに基づいて上位の n 映画を検索します。
結果をコンテンツ評価でアルファベット順にソートします。

詳細

戻る

$top

Update

$topN（アキュムレータ演算子）

定義

構文

動作

NULL および欠損値

BSON データ型ソート順

例

1 つのジャンルで最高評価の映画 3 つを見つける

各ジャンルで最高評価の映画を見つける

グループ キーに基づいて n を動的に設定

詳細

グループキーに基づいて n を動的に設定