Operaciones de agregación

Overview

En esta guía, puede aprender a utilizar el controlador Kotlin Sync para realizar operaciones de agregación.

Puede usar operaciones de agregación para procesar datos en sus colecciones de MongoDB y obtener resultados calculados. El marco de agregación de MongoDB, que forma parte de la API de consultas, se basa en el concepto de una canalización de procesamiento de datos. Los documentos entran en una canalización que contiene una o más etapas, y cada etapa los transforma para generar un resultado agregado final.

Una operación de agregación se puede comparar con una fábrica de automóviles. Una fábrica de automóviles cuenta con una línea de montaje que contiene estaciones de ensamblaje con herramientas especializadas para realizar tareas específicas, como taladros y soldadores. Las piezas en bruto entran en la fábrica y luego la línea de montaje las transforma y ensambla en un producto terminado.

La tubería de agregación es la línea de ensamblaje, las etapas de agregación son las estaciones de ensamblaje y las expresiones del operador son las herramientas especializadas.

Ejemplo de agregación

Los ejemplos de esta sección utilizan la restaurants colección de la base de datos de los sample_restaurants conjuntos de datos de ejemplo de Atlas. Para aprender a crear una implementación gratuita de MongoDB y cargar los conjuntos de datos de ejemplo, consulte la guía de introducción a MongoDB.

La siguiente clase de datos de Kotlin modela los documentos de esta colección:

data class Restaurant(
    val name: String,
    val cuisine: String,
    val borough: String
)

val pipeline = listOf(
    Aggregates.match(Filters.eq(Restaurant::cuisine.name, "Bakery")),
    Aggregates.group("\$borough", Accumulators.sum("count", 1))
)
val results = collection.aggregate<Document>(pipeline)
results.forEach { result ->
    println(result)
}

Document{{_id=Bronx, count=71}}
Document{{_id=Manhattan, count=221}}
Document{{_id=Brooklyn, count=173}}
Document{{_id=Queens, count=204}}
Document{{_id=Staten Island, count=20}}
Document{{_id=Missing, count=2}}

print(collection.aggregate(pipeline).explain())

{
  "explainVersion": "2",
  "queryPlanner": {
      "namespace": "sample_restaurants.restaurants"
      "indexFilterSet": false,
      "parsedQuery": {
        "cuisine": {"$eq": "Bakery"}
      },
      "queryHash": "865F14C3",
      "planCacheKey": "0697561B",
      "optimizedPipeline": true,
      "maxIndexedOrSolutionsReached": false,
      "maxIndexedAndSolutionsReached": false,
      "maxScansToExplodeReached": false,
      "winningPlan": { ... }
      ...
  }
  ...
}

MongoDB búsqueda

Puede realizar una consulta de búsqueda de MongoDB creando y ejecutando una canalización de agregación que contenga una de las siguientes etapas de canalización:

• $search

• $searchMeta

Para obtener más información sobre las etapas de la canalización de búsqueda de MongoDB,consulte Elegir la etapa de la canalización de agregación en la documentación de Atlas. Para ver ejemplos que utilizan el controlador de sincronización de Kotlin para crear etapas de búsqueda de la canalización de búsqueda de MongoDB, consulte la guía "Ejecutar una consulta de búsqueda de MongoDB".

Información Adicional

Para obtener una lista completa de las etapas de agregación, consulta Etapas de agregación en el manual de MongoDB Server.

Para obtener más información sobre cómo ensamblar una canalización de agregación y ver ejemplos, consulte Canalización de agregación en el manual de MongoDB Server.

Para obtener más información sobre cómo explicar las operaciones de MongoDB, consulte Explicar los planes de salida y consulta en el manual del servidor MongoDB.