Etapas de agregación

En el Las etapas del pipeline se db.collection.aggregate()muestran en db.aggregate() una matriz con los métodos y. En la interfaz de usuario de Atlas, puede organizar las etapas del pipeline mediante Generador de canales de agregación. Los documentos pasan por las etapas en secuencia.

db.collection.aggregate() Stages

Todas las etapas, excepto las $out, $merge, $geoNear, $changeStream y $changeStreamSplitLargeEvent pueden aparecer varias veces en un pipeline.

Nota

Para obtener detalles sobre un comando específico, incluida la sintaxis y ejemplos, haga clic en el enlace a la página de referencia del comando.

db.collection.aggregate( [ { <stage> }, ... ] )

Etapa	Descripción
`$addFields`	Agrega nuevos campos a los documentos. De forma similar a `$project`, `$addFields` transforma cada documento en el flujo; específicamente, agregando nuevos campos a los documentos de salida que contienen tanto los campos existentes de los documentos de entrada como los nuevos campos agregados. `$set` es un alias para `$addFields`.
`$bucket`	Clasifica los documentos entrantes en grupos, llamados buckets, basados en una expresión especificada y límites de bucket.
`$bucketAuto`	Clasifica los documentos entrantes en un número específico de grupos, denominados buckets, según una expresión especificada. Los límites de los buckets se determinan de manera automática con el objetivo de distribuir uniformemente los documentos en el número especificado de buckets.
`$changeStream`	Devuelve un cursor de flujo de cambios para la colección. Esta etapa solo puede ocurrir una vez en un pipeline de agregación y debe ser la primera etapa.
`$changeStreamSplitLargeEvent`	Divide los eventos grandes de flujo de cambios que superan los 16 MB en fragmentos más pequeños que se devuelven en un cursor de flujo de cambios. Solo puedes utilizar `$changeStreamSplitLargeEvent` en un pipeline `$changeStream` y debe ser la etapa final del pipeline.
`$collStats`	Devuelve estadísticas sobre una colección o vista.
`$count`	Devuelve un recuento del número de documentos en esta etapa del pipeline de agregación. Distinto del acumulador de agregación `$count`.
`$densify`	Crea nuevos documentos en una secuencia de documentos donde faltan ciertos valores en un campo.
`$documents`	Devuelve documentos literales a partir de expresiones de entrada.
`$facet`	Procesa múltiples canalizaciones de agregación dentro de una sola etapa en el mismo conjunto de documentos de entrada. Permite la creación de agregaciones multifacéticas capaces de caracterizar datos a través de múltiples dimensiones, o facetas, en una sola etapa.
`$fill`	Rellena `null` y los valores de campo faltantes dentro de los documentos.
`$geoNear`	Devuelve un flujo ordenado de documentos en función de la proximidad a un punto geoespacial. Incorpora la funcionalidad de `$match`, `$sort` y `$limit` para datos geoespaciales. Los documentos de salida incluyen un campo adicional de distancia y pueden incluir un campo de identificador de ubicación.
`$graphLookup`	Realiza una búsqueda recursiva en una colección. A cada documento de salida, agrega un nuevo campo de arreglo que contenga los resultados del recorrido de la búsqueda recursiva para ese documento.
`$group`	Agrupa los documentos de entrada mediante una expresión de identificador específica y aplica la expresión del acumulador, si se especifica, a cada grupo. Consume todos los documentos de entrada y produce un documento por cada grupo distinto. Los documentos de salida solo contienen el campo identificador y, si se especifica, los campos acumulados.
`$indexStats`	Devuelve estadísticas sobre el uso de cada índice de la colección.
`$limit`	Pasa los primeros n documentos sin modificar al pipeline donde n es el límite especificado. Para cada documento de entrada, se genera un documento (para los primeros n documentos) o cero documentos (después de los primeros n documentos).
`$listSampledQueries`	Enumera los queries de muestra para todas las colecciones o para una colección específica.
`$listSearchIndexes`	Devuelve información sobre los índices de Atlas Search existentes en una colección específica.
`$listSessions`	Enumera todas las sesiones que han estado activas el tiempo suficiente para propagarse a la colección `system.sessions`.
`$lookup`	Realiza un left outer join a otra colección en la misma base de datos para filtrar documentos de la colección "unida" para su procesamiento.
`$match`	Filtra el flujo de documentos para permitir que solo los documentos coincidentes pasen sin modificaciones a la siguiente etapa del pipeline. `$match` utiliza consultas estándar de MongoDB. Para cada documento de entrada, se genera un documento (si hay coincidencia) o cero documentos (si no hay coincidencia).
`$merge`	Guarda los documentos resultantes del pipeline de agregación en una colección. La etapa puede incorporar (insertar nuevos documentos, fusionar documentos, reemplazar documentos, conservar documentos existentes, fallar la operación, procesar documentos con un pipeline de actualización personalizado) los resultados en una colección de salida. Para usar la etapa `$merge`, debe ser la última etapa del pipeline.
`$out`	Guarda los documentos resultantes del pipeline de agregación en una colección. Para usar la etapa `$out`, debe ser la última etapa del pipeline.
`$planCacheStats`	Devuelve información de la caché de planes para una colección.
`$project`	Reestructura cada documento del flujo, por ejemplo, agregando nuevos campos o removiendo los existentes. Para cada documento de entrada, genera un documento. Consulta también `$unset` para remover campos existentes.
`$queryStats`	Devuelve estadísticas de tiempo de ejecución para los query registrados. ADVERTENCIA: La etapa de agregación `$queryStats` no es compatible y no se garantiza que sea estable en una versión futura. No desarolles funcionalidades que dependan de un formato de salida específico de esta etapa, ya que la salida puede cambiar en una versión futura.
`$redact`	Reconfigura cada documento en la secuencia restringiendo el contenido de cada documento según la información almacenada en los propios documentos. Incorpora la funcionalidad de `$project` y `$match`. Se puede utilizar para implementar la restricción a nivel de campo. Para cada documento de entrada, genera uno o cero documentos.
`$replaceRoot`	Reemplaza un documento con el documento incrustado específico. La operación reemplaza todos los campos existentes en el documento de entrada, incluido el campo `_id`. Especifique un documento incrustado en el documento de entrada para elevar el documento incrustado al nivel superior. `$replaceWith` es un alias para la etapa `$replaceRoot`.
`$replaceWith`	Reemplaza un documento con el documento incrustado específico. La operación reemplaza todos los campos existentes en el documento de entrada, incluido el campo `_id`. Especifique un documento incrustado en el documento de entrada para elevar el documento incrustado al nivel superior. `$replaceWith` es un alias para la etapa `$replaceRoot`.
`$sample`	Selecciona aleatoriamente el número específico de documentos de su entrada.
`$search`	Realiza una búsqueda de texto completo de los campos en una colección de Atlas. `$search` Solo está disponible para clústeres de MongoDB Atlas y no para implementaciones autogestionadas. Para obtener más información, consulte Etapas de la canalización de agregación de búsquedas en Atlas.
`$searchMeta`	Devuelve diferentes tipos de documentos de resultados de metadatos para la consulta de búsqueda de Atlas en una colección de Atlas. `$searchMeta` Solo está disponible para clústeres de MongoDB Atlas y no para implementaciones autogestionadas. Para obtener más información, consulte Etapas de la canalización de agregación de búsquedas en Atlas.
`$set`	Agrega nuevos campos a los documentos. De forma similar a `$project`, `$set` transforma cada documento en el flujo; específicamente, agregando nuevos campos a los documentos de salida que contienen tanto los campos existentes de los documentos de entrada como los nuevos campos agregados. `$set` es un alias para la etapa `$addFields`.
`$setWindowFields`	Agrupa documentos en ventanas y aplica uno o más operadores a los documentos en cada ventana. Nuevo en la versión 5.0.
`$skip`	Omite los primeros documentos n, donde n es el número de omisión especificado, y pasa los documentos restantes sin modificar al pipeline. Para cada documento de entrada, se genera cero documentos (para los primeros documentos n) o un documento (después de los primeros documentos n).
`$sort`	Reordena el flujo de documentos por una clave de ordenación específica. Solo cambia el orden; los documentos permanecen sin modificar. Para cada documento de entrada, genera un documento.
`$sortByCount`	Agrupa los documentos entrantes según el valor de una expresión especificada y luego calcula el número de documentos en cada grupo distinto.
`$unionWith`	Realiza una unión de dos colecciones, es decir, combina los resultados de la canalización de dos colecciones en un único conjunto de resultados.
`$unset`	Remueve/excluye campos de los documentos. `$unset` es un alias para la etapa `$project` que elimina campos.
`$unwind`	Descompone un campo de arreglo de los documentos de entrada para producir un documento por cada elemento. Cada documento de salida reemplaza el arreglo con un valor de elemento. Para cada documento de entrada, genera documentos n, donde n es el número de elementos del arreglo y puede ser cero para un arreglo vacío.
`$vectorSearch`	Realiza una Búsqueda ANN o ENN en un vector en el campo especificado de una colección Atlas. `$vectorSearch` solo está disponible para clústeres de MongoDB Atlas que ejecuten MongoDB v6.0.11 o superior, y no está disponible para implementaciones autogestionadas. Nuevo en la versión 7.0.2.

Para aprender sobre expresiones que puedas usar en etapas del pipeline, consulta Expresiones.

Etapas de db.aggregate()

MongoDB también proporciona el método db.aggregate():

db.aggregate( [ { <stage> }, ... ] )

Las siguientes etapas utilizan el método db.aggregate() y no el método db.collection.aggregate().

Etapa	Descripción
`$changeStream`	Devuelve un cursor de flujo de cambios para la colección. Esta etapa solo puede ocurrir una vez en un pipeline de agregación y debe ser la primera etapa.
`$currentOp`	Devuelve información sobre las operaciones activas y/o inactivas de la implementación de MongoDB.
`$documents`	Devuelve documentos literales desde valores de entrada.
`$listLocalSessions`	Enumera todas las sesiones activas utilizadas recientemente en la instancia actualmente conectada de `mongos` o `mongod`. Es posible que estas sesiones aún no se hayan propagado a la colección `system.sessions`.

Etapas disponibles para actualizaciones

Puedes utilizar el pipeline de agregación para actualizaciones en:

Comando	`mongosh` Métodos
`findAndModify`	db.collection.findOneAndUpdate() db.collection.findAndModify()
`update`	db.collection.updateOne() db.collection.updateMany() Bulk.find.update() Bulk.find.updateOne() Bulk.find.upsert()

Para las actualizaciones, el pipeline puede constar de las siguientes etapas:

$addFields y su alias $set
$project y su alias $unset
$replaceRoot y su alias $replaceWith

Volver

update

$addFields