在该db.collection.aggregate
方法中
db.aggregate
,流水线级以阵列形式出现。文档依次经过各个阶段。
db.collection.aggregate()
阶段¶所有的以外$out
,$merge
和$geoNear
阶段可以在管道中出现多次。
注意
有关特定运算符的详细信息,包括语法和示例,请单击特定运算符以转到其参考页。
阶段 | 描述 |
---|---|
$addFields |
将新字段添加到文档。与相似
|
$bucket |
根据指定的表达式和存储区边界将传入文档分类为多个组,称为存储区。 |
$bucketAuto |
根据指定的表达式将传入文档分类为特定数量的组,称为存储桶。自动确定存储区边界,以尝试将文档平均分配到指定数量的存储区中。 |
$collStats |
返回有关集合或视图的统计信息。 |
$count |
返回聚合管道此阶段的文档数计数。 |
$facet |
在同一阶段的同一组输入文档上处理多个聚合管道。支持在一个阶段中创建能够表征多维或多面数据的多面聚合。 |
$geoNear |
根据与地理空间点的接近程度返回有序的文档流。包含
$match ,$sort 和$limit 用于地理空间数据的功能。输出文档包括附加距离字段,并且可以包括位置标识符字段。 |
$graphLookup |
对集合执行递归搜索。向每个输出文档添加一个新的数组字段,其中包含对该文档的递归搜索的遍历结果。 |
$group |
按指定的标识符表达式对输入文档进行分组,并将累加器表达式(如果指定)应用于每个组。消耗所有输入文档,并在每个不同的组中输出一个文档。输出文档仅包含标识符字段,如果指定,还包含累积字段。 |
$indexStats |
返回有关集合每个索引使用情况的统计信息。 |
$limit |
将未修改的前n个文档传递到管道,其中n是指定的限制。对于每个输入文档,输出一个文档(对于前n个文档)或零文档(在前n个文档之后)。 |
$listSessions |
列出所有活动时间已经足够长以传播到system.sessions 集合的会话。 |
$lookup |
对同一数据库中的另一个集合执行左外部 联接,以过滤“联接”集合中的文档以进行处理。 |
$match |
筛选文档流,以仅允许匹配的文档未经修改地传递到下一个管道阶段。
$match 使用标准的MongoDB查询。对于每个输入文档,输出一个文档(匹配)或零文档(不匹配)。 |
$merge |
将聚合管道的结果文档写入集合。该阶段可以将结果合并(插入新文档,合并文档,替换文档,保留现有文档,使操作失败,使用自定义更新管道处理文档)将结果合并到输出集合中。要使用该 4.2版中的新功能。 |
$out |
将聚合管道的结果文档写入集合。要使用该$out 阶段,它必须是管道中的最后一个阶段。 |
$planCacheStats |
返回集合的计划缓存信息。 |
$project |
重塑流中的每个文档,例如通过添加新字段或删除现有字段。对于每个输入文档,输出一个文档。 另请参阅 |
$redact |
通过基于文档本身中存储的信息限制每个文档的内容,来重塑流中的每个文档。包含$project 和的功能
$match 。可用于实施字段级修订。对于每个输入文档,输出一个或零个文档。 |
$replaceRoot |
用指定的嵌入式文档替换文档。该操作将替换输入文档中的所有现有字段,包括该
|
$replaceWith |
用指定的嵌入式文档替换文档。该操作将替换输入文档中的所有现有字段,包括该
|
$sample |
从其输入中随机选择指定数量的文档。 |
$set |
将新字段添加到文档。与相似
|
$skip |
跳过前n个文档,其中n是指定的跳过编号,并将其余未修改的文档传递到管道。对于每个输入文档,输出零个文档(对于前n个文档)或一个文档(如果在前n个文档之后)。 |
$sort |
通过指定的排序键对文档流重新排序。只有顺序改变;这些文档保持不变。对于每个输入文档,输出一个文档。 |
$sortByCount |
根据指定表达式的值对传入文档进行分组,然后计算每个不同组中的文档数。 |
$unset |
从文档中删除/排除字段。 |
$unwind |
从输入文档中解构一个数组字段,以输出每个元素的文档。每个输出文档用元素值替换数组。对于每个输入文档,输出n个文档,其中n是数组元素的数量,对于空数组可以为零。 |
有关在管道阶段使用的聚合表达式运算符,请参见 聚合管道运算符。
db.aggregate()
阶段¶从3.6版开始,MongoDB还提供以下
db.aggregate
方法:
以下阶段使用db.aggregate()
方法而不是db.collection.aggregate()
方法。
阶段 | 描述 |
---|---|
$currentOp |
返回有关MongoDB部署的活动和/或休眠操作的信息。 |
$listLocalSessions |
列出当前在当前连接mongos 或mongod
实例上使用的所有活动会话。这些会话可能尚未传播到
system.sessions 集合。 |
从MongoDB 4.2开始,您可以使用聚合管道在以下位置进行更新:
命令 | mongo 壳方法 |
---|---|
findAndModify |
|
update |
对于更新,管道可以包括以下阶段:
$addFields
及其别名 $set
$project
及其别名 $unset
$replaceRoot
及其别名$replaceWith
。名称 | 描述 |
---|---|
$addFields |
将新字段添加到文档。输出包含输入文档中所有现有字段和新添加的字段的文档。 |
$bucket |
根据指定的表达式和存储区边界将传入文档分类为多个组,称为存储区。 |
$bucketAuto |
根据指定的表达式将传入文档分类为特定数量的组,称为存储桶。自动确定存储区边界,以尝试将文档平均分配到指定数量的存储区中。 |
$collStats |
返回有关集合或视图的统计信息。 |
$count |
返回聚合管道此阶段的文档数计数。 |
$currentOp |
返回有关MongoDB部署的活动和/或休眠操作的信息。要运行,请使用db.aggregate() 方法。 |
$facet |
在同一阶段的同一组输入文档上处理多个聚合管道。支持在一个阶段中创建能够表征多维或多面数据的多面聚合。 |
$geoNear |
根据与地理空间点的接近程度返回有序的文档流。包含
$match ,$sort 和$limit 用于地理空间数据的功能。输出文档包括附加距离字段,并且可以包括位置标识符字段。 |
$graphLookup |
对集合执行递归搜索。向每个输出文档添加一个新的数组字段,其中包含对该文档的递归搜索的遍历结果。 |
$group |
按指定的标识符表达式对输入文档进行分组,并将累加器表达式(如果指定)应用于每个组。消耗所有输入文档,并在每个不同的组中输出一个文档。输出文档仅包含标识符字段,如果指定,还包含累积字段。 |
$indexStats |
返回有关集合每个索引使用情况的统计信息。 |
$limit |
将未修改的前n个文档传递到管道,其中n是指定的限制。对于每个输入文档,输出一个文档(对于前n个文档)或零文档(在前n个文档之后)。 |
$listLocalSessions |
列出当前在当前连接mongos 或mongod 实例上使用的所有活动会话
。这些会话可能尚未传播到system.sessions 集合。 |
$listSessions |
列出所有活动时间已经足够长以传播到system.sessions 集合的会话。 |
$lookup |
对同一 数据库中的另一个集合执行左外部联接,以过滤“联接”集合中的文档以进行处理。 |
$match |
筛选文档流,以仅允许匹配的文档未经修改地传递到下一个管道阶段。$match
使用标准的MongoDB查询。对于每个输入文档,输出一个文档(匹配)或零文档(不匹配)。 |
$merge |
将聚合管道的结果文档写入集合。该阶段可以将结果合并(插入新文档,合并文档,替换文档,保留现有文档,使操作失败,使用自定义更新管道处理文档)将结果合并到输出集合中。要使用该 4.2版中的新功能。 |
$out |
将聚合管道的结果文档写入集合。要使用该$out 阶段,它必须是管道中的最后一个阶段。 |
$planCacheStats |
返回集合的计划缓存信息。 |
$project |
重塑流中的每个文档,例如通过添加新字段或删除现有字段。对于每个输入文档,输出一个文档。 |
$redact |
通过基于文档本身中存储的信息限制每个文档的内容,来重塑流中的每个文档。包含$project
和的功能$match 。可用于实施字段级修订。对于每个输入文档,输出一个或零个文档。 |
$replaceRoot |
用指定的嵌入式文档替换文档。该操作将替换输入文档中的所有现有字段,包括该_id 字段。指定嵌入在输入文档中的文档以将嵌入的文档提升到顶层。 |
$replaceWith |
用指定的嵌入式文档替换文档。该操作将替换输入文档中的所有现有字段,包括该 的别名 |
$sample |
从其输入中随机选择指定数量的文档。 |
$set |
将新字段添加到文档。输出包含输入文档中所有现有字段和新添加的字段的文档。 的别名 |
$skip |
跳过前n个文档,其中n是指定的跳过编号,并将其余未修改的文档传递到管道。对于每个输入文档,输出零个文档(对于前n个 文档)或一个文档(如果在前n个文档之后)。 |
$sort |
通过指定的排序键对文档流重新排序。只有顺序改变;这些文档保持不变。对于每个输入文档,输出一个文档。 |
$sortByCount |
根据指定表达式的值对传入文档进行分组,然后计算每个不同组中的文档数。 |
$unset |
从文档中删除/排除字段。
|
$unwind |
从输入文档中解构一个数组字段,以输出每个元素的文档。每个输出文档用元素值替换数组。对于每个输入文档,输出n个文档,其中n是数组元素的数量,对于空数组可以为零。 |