通过聚合转换数据

比较聚合与查找操作

下表列出了查找操作可以执行的不同任务，并将它们与聚合操作可以执行的任务进行了比较。聚合框架提供了扩展功能，允许您转换和操作数据。

限制

执行聚合操作时要考虑以下限制：

• 返回的文档不能违反16 MB 的 BSON文档大小限制。

• 默认下，管道阶段的内存限制为 100 MB。您可以通过将 true 值传递给 allowDiskUse() 方法并将该方法链接到 aggregate() 来超过此限制。

• $graphLookup操作符有 100兆字节的严格内存限制，并忽略传递给allowDiskUse() 方法的值。

对文档进行筛选、分组和计数

此代码示例计算纽约每个区的面包店数量。为此，它调用 aggregate() 方法并将聚合管道作为阶段列表传递。代码使用以下 Aggregates 辅助方法构建这些阶段：

• filter()：构建 $match 阶段以过滤cuisine 值为 的文档"Bakery"

• group()：构建 $ 群组阶段以按borough 字段对匹配文档进行群组，从而累积每个不同值的文档计数

val pipeline = Seq(Aggregates.filter(Filters.equal("cuisine", "Bakery")),
                   Aggregates.group("$borough", Accumulators.sum("count", 1))
)
collection.aggregate(pipeline)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

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

解释聚合

要查看有关MongoDB如何执行您的操作的信息，您可以指示MongoDB查询规划器对其进行解释。 MongoDB解释操作时，会返回执行计划和性能统计信息。执行计划是MongoDB完成操作的一种潜在方式。当您指示MongoDB解释一个操作时，默认下它会返回MongoDB执行的计划和任何被拒绝的执行计划。

要解释聚合操作，请将explain() 方法链接到aggregate() 方法。您可以向explain() 传递详细程度，从而修改该方法返回的信息类型和数量。有关详细程度的更多信息，请参阅MongoDB Server手册中的详细程度模式。

以下示例指示MongoDB解释前面的筛选器、分组和计数文档示例中的聚合操作。此代码会将详细程度值 ExplainVerbosity.EXECUTION_STATS传递给explain() 方法，从而将该方法配置为返回描述获胜计划执行情况的统计信息：

val pipelineToExplain = Seq(Aggregates.filter(Filters.equal("cuisine", "Bakery")),
                   Aggregates.group("$borough", Accumulators.sum("count", 1))
)
collection.aggregate(pipelineToExplain)
          .explain(ExplainVerbosity.EXECUTION_STATS)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

{"explainVersion": "2", "queryPlanner": {"namespace": "sample_restaurants.restaurants",
"indexFilterSet": false, "parsedQuery": {"cuisine": {"$eq": "Bakery"}}, "queryHash": "865F14C3",
"planCacheKey": "0FC225DA", "optimizedPipeline": true, "maxIndexedOrSolutionsReached": false,
"maxIndexedAndSolutionsReached": false, "maxScansToExplodeReached": false, "winningPlan":
{"queryPlan": {"stage": "GROUP", "planNodeId": 3, "inputStage": {"stage": "COLLSCAN",
"planNodeId": 1, "filter": {"cuisine": {"$eq": "Bakery"}}, "direction": "forward"}},
...}

运行Atlas全文搜索

要指定对一个或多个字段进行全文搜索，可以创建 $search管道阶段。 Scala驾驶员提供了 Aggregates.search() 辅助方法来创建此阶段。 search() 方法需要以下参数：

• SearchOperator 实例：指定要搜索的字段和文本。

• SearchOptions 实例：指定用于自定义全文搜索的选项。您必须将 index 选项设立为要使用的Atlas Search索引的名称。

此示例创建管道阶段来执行以下操作：

• 在 name字段中搜索包含单词 "Salt" 的文本

• 仅投影匹配文档的 _id 和 name 值

val operator = SearchOperator.text(SearchPath.fieldPath("name"), "Salt")
val options = searchOptions().index("<search index name>")
val pipeline = Seq(Aggregates.search(operator, options),
                   Aggregates.project(Projections.include("name")))
collection.aggregate(pipeline)
          .subscribe((doc: Document) => println(doc.toJson()),
                    (e: Throwable) => println(s"There was an error: $e"))

{"_id": {"$oid": "..."}, "name": "Fresh Salt"}
{"_id": {"$oid": "..."}, "name": "Salt & Pepper"}
{"_id": {"$oid": "..."}, "name": "Salt + Charcoal"}
{"_id": {"$oid": "..."}, "name": "A Salt & Battery"}
{"_id": {"$oid": "..."}, "name": "Salt And Fat"}
{"_id": {"$oid": "..."}, "name": "Salt And Pepper Diner"}

MongoDB Server 手册

要学习；了解有关本指南所讨论主题的更多信息，请参阅MongoDB Server手册中的以下页面：

• 要查看表达式操作符的完整列表，请参阅聚合操作符。

• 要学习；了解如何组装聚合管道并查看示例，请参阅聚合管道。

• 要了解有关创建管道阶段的更多信息，请参阅聚合阶段。

• 要了解有关解释 MongoDB 操作的更多信息，请参阅解释输出和查询计划。

API 文档

要进一步了解本指南所讨论的方法和类型，请参阅以下 API 文档：

• 聚合(aggregate)()

• 聚合

• explain()