聚合(Aggregation)
概述
在本指南中，您可以了解如何使用 MongoDB .NET/C# 驱动程序以执行聚合操作。
聚合操作会对 MongoDB 集合中的数据进行处理，并返回计算结果。MongoDB 聚合框架以数据处理管道的概念为模型。文档通过一个或多个阶段组成的管道流转，该管道将文档转化为聚合结果。
类比
聚合操作的功能类似于带有装配线的汽车工厂。 装配线设有配备专用工具的工位来执行特定任务。 例如，在制造汽车时，装配线从制造车架开始。 然后，当车架移动通过装配线时，每个工位都会组装一个单独的零件。 最终产品即成品汽车。
装配线代表聚合管道，各个工位代表聚合阶段，专用工具代表表达式操作符，而成品则代表聚合结果。
比较聚合与查找操作
下表列出了使用查找操作可以执行的不同任务，同时列出了使用聚合操作可以实现的任务作为对比。聚合框架提供了扩展功能，允许您转换和操作数据。
查找操作 | 聚合操作 |
|---|---|
Select certain documents to return Select which fields to return Sort the results Limit the results Count the results | Select certain documents to return Select which fields to return Sort the results Limit the results Count the results Group the results Rename fields Compute new fields Summarize data Connect and merge data sets |
服务器限制
执行聚合操作时，请考虑以下限制：
返回的文档不得违反 BSON 文档大小限制（16 兆字节）。
默认情况下，管道阶段的内存限制为100 MB。 如果需要，您可以通过设置 AllowDiskUse
AggregateOptions传递给Aggregate()方法的 对象的属性。$graphLookup阶段的内存严格限制为 100 兆字节，并忽略了
AllowDiskUse属性。
聚合示例
如需执行聚合，请向 IMongoCollection<TDocument>.Aggregate() 方法传递聚合阶段列表。
注意
此示例使用Atlas 样本数据集中的sample_restaurants.restaurants集合。要了解如何创建免费的 MongoDB Atlas 集群并加载示例数据集，请参阅快速入门。
下面的代码示例可以统计纽约市每个区的面包店数量。为此，它使用包含以下阶段的聚合管道：
下文将通过使用 LINQ、构建器和 BsonDocument 方法来创建和组合示例管道中使用的聚合阶段，从而实现本示例。
LINQ 方法
// 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); }
要了解有关使用 LINQ 构造聚合管道的更多信息，请参阅 LINQ 指南。
构建者方法
// 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); }
要了解使用构建器构建聚合管道的更多信息，请参阅《使用构建器进行操作》指南中的构建聚合管道部分。
BsonDocument 方法
// 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); }
更多信息
MongoDB Server 手册
要查看表达式操作符的完整列表，请参阅聚合操作符。
要了解有关组装聚合管道的更多信息并查看示例，请参阅聚合管道。
要了解有关创建管道阶段的更多信息，请参阅聚合阶段。
API 文档
有关本指南中讨论的聚合操作的更多信息，请参阅以下 API 文档：