Agregación

Analogía

Las operaciones de agregación funcionan de manera similar a una fábrica de autos. Las fábricas de automóviles tienen una línea de ensamblaje. Las líneas de ensamblaje cuentan con estaciones de ensamblaje y herramientas especializadas para realizar tareas específicas. Para compilar un auto, envía partes sin procesar a la fábrica. Luego, la línea de ensamblaje transforma y ensambla las partes en un automóvil.

La línea de ensamblaje se asemeja al pipeline de agregación, las estaciones de ensamblaje en la línea de ensamblaje se asemejan a las etapas de agregación, las herramientas especializadas representan los operadores de expresión y el producto terminado se asemeja al resultado agregado.

Calificación Promedio

El siguiente ejemplo calcula y muestra la calificación promedio y el número de calificaciones para cada categoría de té.

El pipeline de agregación utiliza la etapa $group para agrupar los documentos por el campo category, calcula el promedio utilizando el operador de expresión $avg y cuenta el número de documentos utilizando el operador de expresión $sum.

// create group stage
groupStage := bson.D{
    {"$group", bson.D{
        {"_id", "$category"},
        {"average_price", bson.D{{"$avg", "$price"}}},
        {"type_total", bson.D{{"$sum", 1}}},
    }}}
// pass the pipeline to the Aggregate() method
cursor, err := coll.Aggregate(context.TODO(), mongo.Pipeline{groupStage})
if err != nil {
    panic(err)
}
// display the results
var results []bson.M
if err = cursor.All(context.TODO(), &results); err != nil {
    panic(err)
}
for _, result := range results {
    fmt.Printf("Average price of %v tea options: $%v \n", result["_id"], result["average_price"])
    fmt.Printf("Number of %v tea options: %v \n\n", result["_id"], result["type_total"])
}

Average price of black tea options: $6.075
Number of black tea options: 4
Average price of green tea options: $5.70
Number of green tea options: 4

Omitir campos en los resultados

El siguiente ejemplo muestra documentos donde puedes conseguir espuma de leche como topping y enumera las dos opciones más económicas.

El pipeline de agregación contiene las siguientes etapas:

• $match etapa para hacer coincidir documentos donde el campo toppings contenga "espuma de leche"

• $unset etapa para omitir los campos _id y category

• $sort etapa para ordenar el price y el toppings en orden ascendente

• $limit escenario para mostrar los dos primeros documentos

// create the stages
matchStage := bson.D{{"$match", bson.D{{"toppings", "milk foam"}}}}
unsetStage := bson.D{{"$unset", bson.A{"_id", "category"}}}
sortStage := bson.D{{"$sort", bson.D{{"price", 1}, {"toppings", 1}}}}
limitStage := bson.D{{"$limit", 2}}
// pass the pipeline to the Aggregate() method
cursor, err := coll.Aggregate(context.TODO(), mongo.Pipeline{matchStage, unsetStage, sortStage, limitStage})
if err != nil {
    panic(err)
}
// display the results
var results []Tea
if err = cursor.All(context.TODO(), &results); err != nil {
    panic(err)
}
for _, result := range results {
    fmt.Printf("Tea: %v \nToppings: %v \nPrice: $%v \n\n", result.Type, strings.Join(result.Toppings, ", "), result.Price)
}

Tea: Hojicha
Toppings: lemon, ginger, milk foam
Price: $5.55
Tea: Gyokuro
Toppings: berries, milk foam
Price: $5.65

Documentación de la API

Para obtener más información sobre cualquiera de los métodos o tipos discutidos en esta guía, consultar la siguiente documentación de la API:

• Aggregate()

• AggregateOptions