$top (acumulador de agregación)

Valores nulos y faltantes

Considera la siguiente agregación que devuelve el documento más alto de un grupo de puntuaciones:

• $top no filtra los valores nulos.

• $top convierte los valores faltantes en 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:
            {
               $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": 1 }
                  }
            }
      }
   }
] )

En este ejemplo:

• $documents crea los documentos literales que contienen las puntuaciones de los jugadores.

• $group agrupa los documentos por gameId. Este ejemplo tiene solo un gameId, G1.

• PlayerD tiene una puntuación faltante y PlayerE tiene un score nulo. Estos valores se consideran ambos nulos.

• Los campos playerId y score se especifican como output : ["$playerId"," $score"] y se devuelven como valores de un arreglo.

• Especifica el orden de clasificación con sortBy: { "score": 1 }.

• PlayerD y PlayerE empató en el elemento superior. PlayerD se devuelve como el score superior.

• Para tener un comportamiento de desempate más determinista para múltiples valores nulos, agregue más campos a sortBy.

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

Compatibilidad con funciones de ventana y expresiones de agregación

$top no es compatible como expresión de agregación.

$top es compatible como un window operator.

Consideraciones sobre el límite de memoria

Las pipelines de agregación que llaman a $top están sujetas al límite de 100 MB. Si se supera este límite para un grupo individual, la agregación falla con un error.

Encontrar la parte superior Score

Puedes utilizar el acumulador $top para encontrar la puntuación más alta en un solo juego.

db.gamescores.aggregate( [
   {
      $match : { gameId : "G1" }
   },
   {
      $group:
         {
            _id: "$gameId",
            playerId:
               {
                  $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": -1 }
                  }
               }
         }
   }
] )

El ejemplo de canalización:

• Utiliza para filtrar los resultados según un $match único.gameId En esteG1 caso,.

• Usa para agrupar los $group resultados gameId por. En esteG1 caso,.

• Especifica los campos que se muestran para $top con output : ["$playerId"," $score"].

• Utiliza sortBy: { "score": -1 } para ordenar los puntajes en orden descendente.

• Utiliza $top para devolver la puntuación más alta en el juego.

La operación devuelve los siguientes resultados:

[ { _id: 'G1', playerId: [ 'PlayerC', 99 ] } ]

Encuentra los mejores Score en varios juegos

Puedes usar el acumulador $top para encontrar los mejores score en cada juego.

db.gamescores.aggregate( [
      {
         $group:
         { _id: "$gameId", playerId:
            {
               $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": -1 }
                  }
            }
         }
      }
] )

El ejemplo de canalización:

• Utiliza $group para agrupar los resultados por gameId.

• Utiliza $top para devolver el score superior para cada juego.

• Especifica los campos que se muestran para $top con output : ["$playerId", "$score"].

• Utiliza sortBy: { "score": -1 } para ordenar los puntajes en orden descendente.

La operación devuelve los siguientes resultados:

[
   { _id: 'G2', playerId: [ 'PlayerD', 80 ] },
   { _id: 'G1', playerId: [ 'PlayerC', 99 ] }
]