Agregación

Overview

En esta guía, puede 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 pasa al método Aggregate().

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

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 genera un recuento del número de panaderías en cada distrito de la ciudad de Nueva York. Para ello, utiliza una canalización de agregación que consta de las siguientes etapas:

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

• Una etapa de $group para agrupar los documentos coincidentes por el borough campo, acumulando un recuento 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