Agregación

Analogía

Las operaciones de agregación funcionan de forma similar a una fábrica de automóviles. Las fábricas de automóviles cuentan con una línea de montaje. Estas líneas cuentan con estaciones de montaje con herramientas especializadas para realizar una tarea específica. Para fabricar un automóvil, se envían piezas en bruto a la fábrica. Luego, la línea de montaje transforma y ensambla las piezas para formar el automóvil.

La línea de ensamblaje se asemeja a la tubería 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.

Puntuación promedio

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

La canalización 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 la cantidad de documentos utilizando el operador de expresión $sum.

groupStage := bson.D{
	{"$group", bson.D{
		{"_id", "$category"},
		{"average_price", bson.D{{"$avg", "$price"}}},
		{"type_total", bson.D{{"$sum", 1}}},
	}}}
// Performs the aggregation and prints the results
cursor, err := coll.Aggregate(context.TODO(), mongo.Pipeline{groupStage})
if err != nil {
	panic(err)
}
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 compara documentos donde puedes conseguir espuma de leche como aderezo y enumera las dos opciones más económicas.

El proceso de agregación contiene las siguientes etapas:

• $match Etapa para hacer coincidir documentos donde el campo toppings contiene "espuma de leche"

• $unset etapa para omitir los campos _id y category

• $sort Etapa para ordenar price y toppings en orden ascendente

• $limit escenario para mostrar los dos primeros documentos

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}}
// Performs the aggregation and prints the results
cursor, err := coll.Aggregate(context.TODO(), mongo.Pipeline{matchStage, unsetStage, sortStage, limitStage})
if err != nil {
	panic(err)
}
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:

• Agregar()

• Opciones agregadas