Operaciones de agregación

Overview

En esta guía, puedes aprender cómo utilizar el driver Sync de Kotlin para realizar operaciones de agregación.

Puede usar operaciones de agregación para procesar datos en sus colecciones de MongoDB y devolver resultados calculados. El marco de agregación de MongoDB, que forma parte de la API de query, está basado en el concepto de una pipeline de procesamiento de datos. Los documentos ingresan en una pipeline que contiene una o más etapas, y cada etapa transforma los documentos para producir un resultado final agregado.

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

La pipeline de agregación es la cadena de ensamblaje, las etapas de agregación son las estaciones de ensamblaje y las expresiones de operadores son las herramientas especializadas.

Ejemplo de agregación

Los ejemplos de esta sección utilizan la colección restaurants en la base de datos sample_restaurants de los conjuntos de datos de muestra de Atlas. Para aprender cómo crear una implementación gratuita de MongoDB y cargar los conjuntos de datos de muestra, consulta la guía de MongoDB Comenzar.

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

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

• $search

• $searchMeta

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

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 aprender sobre cómo ensamblar una pipeline de agregación y ver ejemplos, consulte Pipeline de agregación en el manual del MongoDB Server.

Para aprender más sobre cómo explicar las operaciones de MongoDB, consulta Salida de explicación y Planes de consultas en el manual de MongoDB Server.