$out (agregación)

Comparación con $merge

Con la introducción de en $merge la 4.2 versión, MongoDB ofrece dos etapas, y, para escribir los resultados de la canalización de agregación en una colección. A continuación, se resumen las capacidades de ambas$merge $outetapas:

Ejecutar operaciones de lectura $out en nodos secundarios del set de réplicas

A partir de MongoDB,5.0 $out puede ejecutarse en nodos secundarios del conjunto de réplicas si todos los nodos del clúster tienen featureCompatibilityVersion configurado en 5.0 o superior y la preferencia de lectura está configurada en secundaria.

Las operaciones de lectura de la $out instrucción ocurren en los nodos secundarios, mientras que las operaciones de escritura ocurren solo en los nodos primarios.

No todas las versiones del controlador admiten la asignación de $out operaciones a nodos secundarios del conjunto de réplicas. Consulte la documentación del controlador para ver cuándo se agregó compatibilidad con $out ejecutándose en un nodo secundario.

Crear nueva colección

La operación crea una nueva colección si aún no existe $out una.

La colección aparece cuando se completa la agregación. Si la agregación falla, MongoDB no crea la colección.

Sustituir la colección existente

Si la colección especificada por la operación ya existe,$out al finalizar la agregación, la etapa reemplaza automáticamente la colección existente con $out $out la nueva colección de resultados. En concreto, la operación:

1. Crea una colección temporal.

2. Copia los índices de la colección existente a la colección temporal.

3. Inserta los documentos en la colección temporal.

4. Llama al comando renameCollection con dropTarget: true para renombrar la colección temporal a la colección de destino.

La operación no modifica ningún índice existente en $out $out la colección anterior. Si la agregación falla, la operación no modifica la colección preexistente.

Restricciones de índices

El pipeline no se completará si los documentos producidos por el mismo violan algunos índices únicos, incluido el índice en el campo _id de la colección de salida original.

Si la operación $out modifica una colección con un índice Atlas Search, debe eliminar y volver a crear el índice de búsqueda. Considere usar $merge en su lugar.

majority readConcern

Puede especificar el nivel de consistencia de lectura "majority" para una agregación que incluya una etapa $out.

Interacción con mongodump

Un mongodump iniciado con falla si un --oplog $out cliente emite una canalización de agregación que incluye mongodump --oplog durante el proceso de volcado. Consulte para obtener más información.

Restricciones

Salida a la misma base de datos

La siguiente operación de agregación dinamiza los datos de la colección books en la base de datos test para tener los títulos agrupados por autores y, a continuación, guarda los resultados en la colección authors, también en la base de datos test.

db.getSiblingDB("test").books.aggregate( [
    { $group : { _id : "$author", books: { $push: "$title" } } },
    { $out : "authors" }
] )

Primera etapa ($group):

La etapa de $group agrupa por authors y utiliza $push para añadir los títulos a un campo de arreglo books:

{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }
{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }

Segunda etapa ($out):

La etapa envía los documentos a $out la authors colección en la test base de datos.

Para ver los documentos en la colección de salida, ejecute la siguiente operación:

db.getSiblingDB("test").authors.find()

La colección contiene los siguientes documentos:

{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }
{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }

Salida a una base de datos diferente

$out puede generar salida a una colección en una base de datos diferente de donde se ejecuta la agregación.

La siguiente operación de agregación dinamiza los datos de la colección books para agrupar los títulos por autores y luego guarda los resultados en la colección authors de la base de datos reporting:

db.getSiblingDB("test").books.aggregate( [
    { $group : { _id : "$author", books: { $push: "$title" } } },
    { $out : { db: "reporting", coll: "authors" } }
] )

Primera etapa ($group):

La etapa de $group agrupa por authors y utiliza $push para añadir los títulos a un campo de arreglo books:

{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }
{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }

Segunda etapa ($out):

La etapa envía los documentos a $out la authors colección en la reporting base de datos.

Para ver los documentos en la colección de salida, ejecute la siguiente operación:

db.getSiblingDB("reporting").authors.find()

La colección contiene los siguientes documentos:

{ "_id" : "Homer", "books" : [ "The Odyssey", "Iliad" ] }
{ "_id" : "Dante", "books" : [ "The Banquet", "Divine Comedy", "Eclogues" ] }