Agregación

Overview

En esta guía, puedes aprender a utilizar el controlador MongoDB .NET/C# para realizar operaciones de agregación.

Las operaciones de agregación procesan los datos en las colecciones de MongoDB y devuelven resultados calculados. El marco de agregación de MongoDB está modelado según el concepto de pipeline de procesamiento de datos. Los documentos entran en un pipeline compuesto por una o varias etapas, y este pipeline transforma los documentos en un resultado agregado.

Comparar las operaciones de agregación y búsqueda

La siguiente tabla enumera las diferentes tareas que se pueden realizar con las operaciones de búsqueda, en comparación con las que se pueden lograr con las operaciones de agregación. El marco de agregación ofrece una funcionalidad ampliada que permite transformar y manipular los datos.

Limitaciones del servidor

Considere lo siguiente limitaciones al realizar operaciones de agregación:

• Los documentos devueltos no deben violar el límite de tamaño de documento BSON de 16 megabytes.

• Las etapas de pipeline tienen un límite de memoria de 100 megabytes por defecto. Si es necesario, puede superar este límite configurando la propiedad AllowDiskUse del AggregateOptions objeto que se pasa al método Aggregate().

• La etapa $graphLookup tiene un límite estricto de memoria de 100 megabytes y omite la propiedad AllowDiskUse.

Ejemplo de agregación

Para realizar una agregación, pase una lista de etapas de agregación al método IMongoCollection<TDocument>.Aggregate().

El siguiente ejemplo de código produce un recuento del número de panaderías en cada distrito de la ciudad de Nueva York. Para ello, utiliza una pipeline de agregación que contiene las siguientes etapas:

• Una etapa $match para filtrar documentos cuyo campo cuisine contenga el valor "Bakery".

• Una etapa $group para agrupar los documentos coincidentes por el campo borough, acumulando un conteo de documentos para cada valor distinto de ese campo.

Las siguientes secciones implementan este ejemplo mediante el uso de los enfoques LINQ, Builders y BsonDocument para crear y combinar las etapas de agregación utilizadas en la canalización de ejemplo.

// Defines a queryable collection object as a prerequisite to using LINQ
var queryableCollection = collection.AsQueryable();
// Defines the query with $match and $group stages
var query = queryableCollection
    .Where(r => r.Cuisine == "Bakery")
    .GroupBy(r => r.Borough)
    .Select(g => new { _id = g.Key, Count = g.Count() });
// Executes the query and prints the aggregated results
foreach (var result in query.ToList())
{
    Console.WriteLine(result);
}

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

// Defines the $match aggregation stage  
var matchFilter = Builders<Restaurant>.Filter.Eq(r => r.Cuisine, "Bakery");
// Defines the aggregation pipeline with the $match and $group aggregation stages
var pipeline = new EmptyPipelineDefinition<Restaurant>()
    .Match(matchFilter)
    .Group(r => r.Borough,
        g => new
            {
                _id = g.Key,
                Count = g.Count()
            }
    );
// Executes the aggregation pipeline
var results = collection.Aggregate(pipeline).ToList();
// Prints the aggregated results
foreach (var result in results)
{
    Console.WriteLine(result);
}

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

// Defines the $match and $group aggregation stages
var matchStage = new BsonDocument
{
    {
        "$match",
        new BsonDocument
        {
            { "cuisine", "Bakery" }
        }
    }
};
var groupStage = new BsonDocument
{
    {
        "$group",
        new BsonDocument
        {
            { "_id", "$borough" },
            { "count", new BsonDocument("$sum", 1) }
        }
    }
};
// Executes the aggregation pipeline
var pipeline = new[] { matchStage, groupStage };
var results = collection.Aggregate<BsonDocument>(pipeline).ToList();
// Prints the aggregated results
foreach (BsonDocument result in results)
{
    Console.WriteLine(result);
}

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

Información Adicional