db.collection.aggregate()
最后更新于
最后更新于
在本页面
db.collection.
aggregate
(管道,选项)
计算集合中数据的聚合值或视图。
参数 | 类型 | 描述 |
---|---|---|
options
文档可以包含以下字段和值:
字段 | 类型 | 描述 |
---|---|---|
如果发生错误,aggregate()帮助程序将抛出 exception。
在mongo shell 中,如果从db.collection.aggregate()返回的游标未使用var
关键字分配给变量,则mongo shell 会自动迭代光标 20 次。请参阅在 mongo Shell 中迭代一个 Cursor以处理mongo shell 中的游标。
从聚合返回的游标仅支持对已评估的游标(已检索其第一批的,即:游标)进行操作的游标方法,例如以下方法:
也可以看看
有关更多信息,请参阅聚合管道,聚合参考,聚合管道限制和聚合。
版本4.0中的新功能。
对于在会话内创建的游标,不能在getMore
会话外调用 。
同样,对于在会话外部创建的游标,不能在getMore
会话内部调用 。
从MongoDB 3.6开始,MongoDB驱动程序和mongo
shell程序将所有操作与服务器会话相关联,但未确认的写操作除外。对于未与会话明确关联的操作(即使用Mongo.startSession()
),MongoDB驱动程序和mongo
shell程序会创建一个隐式会话并将其与该操作相关联。
如果会话空闲时间超过30分钟,则MongoDB服务器会将会话标记为已过期,并可以随时关闭它。当MongoDB服务器关闭会话时,它还会终止所有正在进行的操作并打开与该会话关联的游标。这包括配置了30分钟noCursorTimeout
或maxTimeMS
30分钟以上的光标。
对于返回游标的操作,如果游标可能闲置了30分钟以上,请在显式会话中使用发出操作,Session.startSession()
并使用refreshSessions
命令定期刷新该会话。请参阅 以获取更多信息。Session Idle Timeout
db.collection.aggregate()
可以在多文档事务中使用。
但是,事务中不允许以下阶段:
$collStats
$currentOp
$indexStats
$listLocalSessions
$listSessions
$out
$merge
$planCacheStats
您也不能指定该explain
选项。
对于在事务外部创建的游标,不能getMore
在事务内部调用 。
对于在事务中创建的游标,不能getMore
在事务外部调用 。
重要
在大多数情况下,与单文档写入相比,多文档事务产生的性能成本更高,并且多文档事务的可用性不应替代有效的架构设计。在许多情况下, 非规范化数据模型(嵌入式文档和数组)将继续是您的数据和用例的最佳选择。也就是说,在许多情况下,适当地对数据建模将最大程度地减少对多文档交易的需求。
有关其他事务使用方面的注意事项(例如运行时限制和操作日志大小限制),另请参见 生产注意事项。
对于db.collection.aggregate()
不包含$out
或$merge
阶段的操作:
从MongoDB 4.2开始,如果发出db.collection.aggregate()
断开连接的客户端在操作完成之前断开连接,则MongoDB将标记db.collection.aggregate()
为终止(即在操作上killOp
)。
以下示例使用包含以下文档的集合orders
:
以下聚合操作选择状态等于"A"
的文档,按cust_id
字段对匹配文档进行分组,并从amount
字段的总和计算每个cust_id
字段的total
,并按降序 order 中的total
字段对结果进行排序:
该操作返回带有以下文档的游标:
mongo shell 自动迭代返回的光标以打印结果。有关在mongo shell 中手动处理游标的信息,请参阅在 mongo Shell 中迭代一个 Cursor。
以下聚合操作将选项explain
设置为true
以_return 有关聚合操作的信息。
该操作返回带有文档的游标,该文档包含有关聚合管道处理的详细信息。例如,除了其他细节之外,文档可以显示所使用的操作的索引(如果有的话)。 [1]如果orders
集合是分片集合,则文档还将显示分片和合并操作之间的分工,以及目标查询,目标分片。
注意
explain
输出文档的预期 readers 是人类,而不是机器,输出格式可能会在不同版本之间发生变化。
mongo shell 自动迭代返回的光标以打印结果。有关在mongo shell 中手动处理游标的信息,请参阅在 mongo Shell 中迭代一个 Cursor。
[1]索引过滤器会影响所用索引的选择。有关详细信息,请参见索引过滤器。
聚合管道阶段有最大 memory 使用限制。要处理大型数据集,请将allowDiskUse
选项设置为true
以启用将数据写入临时 files,如下面的示例所示:
从MongoDB 4.2开始,事件profiler log massages和diagnostic log massages包括一个usedDisk
指示符,指示是否有任何聚合阶段由于内存限制而将数据写入临时文件。
要指定游标的初始批处理大小,请对cursor
选项使用以下语法:
对于 example,以下聚合操作指定游标的初始批处理大小0
:
A batchSize
0
表示空的第一批,对于快速返回游标或失败消息而不执行重要的 server-side 工作非常有用。与其他 MongoDB 游标一样,将后续批量大小指定为OP_GET_MORE操作。
mongo shell 自动迭代返回的光标以打印结果。有关在mongo shell 中手动处理游标的信息,请参阅在 mongo Shell 中迭代一个 Cursor。
version 3.4 中的新内容。
整理允许用户为 string 比较指定 language-specific 规则,例如字母和重音标记的规则。
集合myColl
具有以下文档:
以下聚合操作包括整理选项:
注意
如果执行涉及多个视图的聚合(例如$lookup或$graphLookup),则视图必须具有相同的整理。
有关归类字段的说明,请参阅整理文件。
version 3.6 中的新内容。
使用以下文档创建集合foodColl
:
创建以下索引:
以下聚合操作包括强制使用指定索引的hint
选项:
使用该readConcern
选项可以指定操作的读取关注点。
您不能将$out
或$merge
阶段与阅读关注结合使用"linearizable"
。也就是说,如果您为指定了"linearizable"
读取关注 db.collection.aggregate()
,则不能在管道中包括任何一个阶段。
对副本集的以下操作指定“ 读取关注点”,"majority"
以读取已确认已写入大多数节点的数据的最新副本。
注意
要使用“多数”的阅读关注 level,replica sets 必须使用WiredTiger 存储引擎并选举protocol version 1。从 MongoDB 3.6 开始,默认情况下启用对读取问题“多数”的支持。对于 MongoDB 3.6.1 - 3.6.x,您可以禁用读取关注“多数”。有关更多信息,请参阅禁用阅读关注多数。
要确保单个线程可以读取自己的写入,请对副本集的主要使用“多数”读取关注和“多数”写入问题。
要使用“多数”的阅读关注 level,您不能包含$out阶段。
无论阅读关注 level 如何,节点上的最新数据可能无法反映系统中数据的最新 version。
名为movies
的集合包含格式如下的文档:
以下聚合操作查找在 1995 年创建的影片,并包含comment
选项以在logs
,db.system.profile
集合和db.currentOp
中提供跟踪信息。
在启用了性能分析的系统上,您可以查询system.profile
集合以查看所有最近的类似聚合,如下所示:
这将以下列格式返回一组探查器结果:
应用程序可以编码 order 中的任意信息,以便更轻松地跟踪或识别系统中的特定操作。例如,application 可能附加 string comment,其中包含 process ID,线程 ID,client 主机名和发出命令的用户。
译者:李冠飞
校对: