$bucket (etapa de agregación)

Agrupar por año y aplicar un filtro por resultados de buckets

En mongosh, cree una colección de muestra llamada artists con los siguientes documentos:

db.artists.insertMany([
  { "_id" : 1, "last_name" : "Bernard", "first_name" : "Emil", "year_born" : 1868, "year_died" : 1941, "nationality" : "France" },
  { "_id" : 2, "last_name" : "Rippl-Ronai", "first_name" : "Joszef", "year_born" : 1861, "year_died" : 1927, "nationality" : "Hungary" },
  { "_id" : 3, "last_name" : "Ostroumova", "first_name" : "Anna", "year_born" : 1871, "year_died" : 1955, "nationality" : "Russia" },
  { "_id" : 4, "last_name" : "Van Gogh", "first_name" : "Vincent", "year_born" : 1853, "year_died" : 1890, "nationality" : "Holland" },
  { "_id" : 5, "last_name" : "Maurer", "first_name" : "Alfred", "year_born" : 1868, "year_died" : 1932, "nationality" : "USA" },
  { "_id" : 6, "last_name" : "Munch", "first_name" : "Edvard", "year_born" : 1863, "year_died" : 1944, "nationality" : "Norway" },
  { "_id" : 7, "last_name" : "Redon", "first_name" : "Odilon", "year_born" : 1840, "year_died" : 1916, "nationality" : "France" },
  { "_id" : 8, "last_name" : "Diriks", "first_name" : "Edvard", "year_born" : 1855, "year_died" : 1930, "nationality" : "Norway" }
])

La siguiente operación agrupa los documentos en buckets según el campo year_born y los filtra basándose en el número de documentos en los buckets:

 db.artists.aggregate( [
 // First Stage
 {
   $bucket: {
     groupBy: "$year_born",                        // Field to group by
     boundaries: [ 1840, 1850, 1860, 1870, 1880 ], // Boundaries for the buckets
     default: "Other",                             // Bucket ID for documents which do not fall into a bucket
     output: {                                     // Output for each bucket
       "count": { $sum: 1 },
       "artists" :
         {
           $push: {
             "name": { $concat: [ "$first_name", " ", "$last_name"] },
             "year_born": "$year_born"
           }
         }
     }
   }
 },
 // Second Stage
 {
   $match: { count: {$gt: 3} }
 }
] )

Primera etapa

La etapa $bucket agrupa los documentos en buckets según el campo year_born. Los buckets tienen los siguientes límites:

• [1840, 1850) con límite inferior inclusivo 1840 y límite superior exclusivo 1850.

• [1850, 1860) con límite inferior inclusivo 1850 y límite superior exclusivo 1860.

• [1860, 1870) con límite inferior inclusivo 1860 y límite superior exclusivo 1870.

• [1870, 1880) con límite inferior inclusivo 1870 y límite superior exclusivo 1880.

• Si un documento no contenía el campo year_born o su campo year_born estaba fuera de los rangos anteriores, se colocaría en el depósito por defecto con el valor _id "Other".

La etapa incluye el documento de salida para determinar los campos a devolver:

Campo	Descripción
_id	Límite inferior inclusivo del bucket.
count	Cantidad de documentos en el bucket.
artists	Arreglo de documentos que contienen información sobre cada artista en el bucket. Cada documento contiene la información del artista. name, que es una concatenación (es decir, $concat) de la first_name y last_name del artista. year_born

Esta etapa pasa los siguientes documentos a la siguiente etapa:

{ "_id" : 1840, "count" : 1, "artists" : [ { "name" : "Odilon Redon", "year_born" : 1840 } ] }
{ "_id" : 1850, "count" : 2, "artists" : [ { "name" : "Vincent Van Gogh", "year_born" : 1853 },
                                            { "name" : "Edvard Diriks", "year_born" : 1855 } ] }
{ "_id" : 1860, "count" : 4, "artists" : [ { "name" : "Emil Bernard", "year_born" : 1868 },
                                            { "name" : "Joszef Rippl-Ronai", "year_born" : 1861 },
                                            { "name" : "Alfred Maurer", "year_born" : 1868 },
                                            { "name" : "Edvard Munch", "year_born" : 1863 } ] }
{ "_id" : 1870, "count" : 1, "artists" : [ { "name" : "Anna Ostroumova", "year_born" : 1871 } ] }

Segunda etapa

La etapa $match filtra la salida de la etapa anterior para devolver solo los buckets que contienen más de 3 documentos.

La operación devuelve el siguiente documento:

{ "_id" : 1860, "count" : 4, "artists" :
  [
    { "name" : "Emil Bernard", "year_born" : 1868 },
    { "name" : "Joszef Rippl-Ronai", "year_born" : 1861 },
    { "name" : "Alfred Maurer", "year_born" : 1868 },
    { "name" : "Edvard Munch", "year_born" : 1863 }
  ]
}

Utiliza $bucket con $facet para clasificar por múltiples campos

Puedes usar la etapa $facet para realizar múltiples agregaciones $bucket en una sola etapa.

En mongosh, cree una colección de muestra llamada artwork con los siguientes documentos:

db.artwork.insertMany([
  { "_id" : 1, "title" : "The Pillars of Society", "artist" : "Grosz", "year" : 1926,
      "price" : Decimal128("199.99") },
  { "_id" : 2, "title" : "Melancholy III", "artist" : "Munch", "year" : 1902,
      "price" : Decimal128("280.00") },
  { "_id" : 3, "title" : "Dancer", "artist" : "Miro", "year" : 1925,
      "price" : Decimal128("76.04") },
  { "_id" : 4, "title" : "The Great Wave off Kanagawa", "artist" : "Hokusai",
      "price" : Decimal128("167.30") },
  { "_id" : 5, "title" : "The Persistence of Memory", "artist" : "Dali", "year" : 1931,
      "price" : Decimal128("483.00") },
  { "_id" : 6, "title" : "Composition VII", "artist" : "Kandinsky", "year" : 1913,
      "price" : Decimal128("385.00") },
  { "_id" : 7, "title" : "The Scream", "artist" : "Munch", "year" : 1893
      /* No price*/ },
  { "_id" : 8, "title" : "Blue Flower", "artist" : "O'Keefe", "year" : 1918,
      "price" : Decimal128("118.42") }
])

La siguiente operación utiliza dos $bucket etapas dentro de una etapa $facet para crear dos agrupaciones, una por price y otra por year:

db.artwork.aggregate( [
  {
    $facet: {                               // Top-level $facet stage
      "price": [                            // Output field 1
        {
          $bucket: {
              groupBy: "$price",            // Field to group by
              boundaries: [ 0, 200, 400 ],  // Boundaries for the buckets
              default: "Other",             // Bucket ID for documents which do not fall into a bucket
              output: {                     // Output for each bucket
                "count": { $sum: 1 },
                "artwork" : { $push: { "title": "$title", "price": "$price" } },
                "averagePrice": { $avg: "$price" }
              }
          }
        }
      ],
      "year": [                                      // Output field 2
        {
          $bucket: {
            groupBy: "$year",                        // Field to group by
            boundaries: [ 1890, 1910, 1920, 1940 ],  // Boundaries for the buckets
            default: "Unknown",                      // Bucket ID for documents which do not fall into a bucket
            output: {                                // Output for each bucket
              "count": { $sum: 1 },
              "artwork": { $push: { "title": "$title", "year": "$year" } }
            }
          }
        }
      ]
    }
  }
] )

Primer faceta

La primera faceta agrupa los documentos de entrada por price. Los intervalos tienen los siguientes límites:

• [0, 200) con límite inferior inclusivo 0 y límite superior exclusivo 200.

• [200, 400) con límite inferior inclusivo 200 y límite superior exclusivo 400.

• "Other", el bucket default que contiene documentos sin precios o precios fuera de los rangos anteriores.

La etapa $bucket incluye el documento de salida para determinar los campos que se deben devolver:

Campo	Descripción
_id	Límite inferior inclusivo del bucket.
count	Cantidad de documentos en el bucket.
artwork	Arreglo de documentos que contienen información sobre cada obra de arte en el bucket.
averagePrice	Emplea el operador $avg para mostrar el precio promedio de todas las obras de arte en el bucket.

Segunda faceta

La segunda faceta agrupa los documentos de entrada por year. Los contenedores tienen los siguientes límites:

• [1890, 1910) con límite inferior inclusivo 1890 y límite superior exclusivo 1910.

• [1910, 1920) con límite inferior inclusivo 1910 y límite superior exclusivo 1920.

• [1920, 1940) con límite inferior inclusivo 1910 y límite superior exclusivo 1940.

• "Desconocido", el contenedor de default que contiene documentos sin años o años fuera de los rangos anteriores.

La etapa $bucket incluye el documento de salida para determinar los campos que se deben devolver:

Campo	Descripción
count	Cantidad de documentos en el bucket.
artwork	Arreglo de documentos que contienen información sobre cada obra de arte en el bucket.

Salida

La operación devuelve el siguiente documento:

 {
  "price" : [ // Output of first facet
    {
      "_id" : 0,
      "count" : 4,
      "artwork" : [
        { "title" : "The Pillars of Society", "price" : Decimal128("199.99") },
        { "title" : "Dancer", "price" : Decimal128("76.04") },
        { "title" : "The Great Wave off Kanagawa", "price" : Decimal128("167.30") },
        { "title" : "Blue Flower", "price" : Decimal128("118.42") }
      ],
      "averagePrice" : Decimal128("140.4375")
    },
    {
      "_id" : 200,
      "count" : 2,
      "artwork" : [
        { "title" : "Melancholy III", "price" : Decimal128("280.00") },
        { "title" : "Composition VII", "price" : Decimal128("385.00") }
      ],
      "averagePrice" : Decimal128("332.50")
    },
    {
      // Includes documents without prices and prices greater than 400
      "_id" : "Other",
      "count" : 2,
      "artwork" : [
        { "title" : "The Persistence of Memory", "price" : Decimal128("483.00") },
        { "title" : "The Scream" }
      ],
      "averagePrice" : Decimal128("483.00")
    }
  ],
  "year" : [ // Output of second facet
    {
      "_id" : 1890,
      "count" : 2,
      "artwork" : [
        { "title" : "Melancholy III", "year" : 1902 },
        { "title" : "The Scream", "year" : 1893 }
      ]
    },
    {
      "_id" : 1910,
      "count" : 2,
      "artwork" : [
        { "title" : "Composition VII", "year" : 1913 },
        { "title" : "Blue Flower", "year" : 1918 }
      ]
    },
    {
      "_id" : 1920,
      "count" : 3,
      "artwork" : [
        { "title" : "The Pillars of Society", "year" : 1926 },
        { "title" : "Dancer", "year" : 1925 },
        { "title" : "The Persistence of Memory", "year" : 1931 }
      ]
    },
    {
      // Includes documents without a year
      "_id" : "Unknown",
      "count" : 1,
      "artwork" : [
        { "title" : "The Great Wave off Kanagawa" }
      ]
    }
  ]
}