aggregate

在本页面

• Syntax

• Sessions

• Example

• aggregate
  • 使用aggregation pipeline执行聚合操作。管道允许用户使用一系列基于阶段的操作来处理来自集合或其他来源的数据。

Syntax

该命令具有以下语法：

在版本 3.6 中更改。

{
  aggregate: "<collection>" || 1,
  pipeline: [ <stage>, <...> ],
  explain: <boolean>,
  allowDiskUse: <boolean>,
  cursor: <document>,
  maxTimeMS: <int>,
  bypassDocumentValidation: <boolean>,
  readConcern: <document>,
  collation: <document>,
  hint: <string or document>,
  comment: <string>,
  writeConcern: <document>
}

Command Fields

aggregate命令采用以下字段作为参数：

有关聚合管道Aggregation Pipeline，Aggregation Reference和聚合管道限制的更多信息。

Sessions

会话空闲超时

从 MongoDB 3.6 开始，MongoDB 驱动程序和mongo shell 将所有操作与server session关联，但未确认的写操作除外。对于未与会话明确关联的操作(即使用Mongo.startSession())，MongoDB 驱动程序和mongo Shell 创建隐式会话并将其与该操作相关联。

如果会话空闲时间超过 30 分钟，则 MongoDB 服务器会将会话标记为已过期，并可以随时关闭它。当 MongoDB 服务器关闭会话时，它还会终止所有正在进行的操作并打开与该会话关联的游标。这包括配置为noCursorTimeout或maxTimeMS大于 30 分钟的光标。

对于返回游标的操作，如果游标可能闲置了 30 分钟以上，请在使用Session.startSession()的显式会话中发出操作，并使用refreshSessions命令定期刷新该会话。有关更多信息，请参见会话空闲超时。

Example

在版本 3.4 中进行了更改：MongoDB 3.6 删除了不使用aggregate命令的情况，而没有使用cursor选项，除非该命令包含explain选项。除非包含explain选项，否则必须指定游标选项。

要指示具有默认批处理大小的光标，请指定cursor: {}。

要使用非默认批处理大小指示光标，请使用cursor: { batchSize: <num> }。

大多数用户应该直接使用mongo shell 中提供的db.collection.aggregate() helper 或驱动程序中的等效帮助程序，而不是直接运行aggregate命令。在 2.6 及更高版本中，db.collection.aggregate()帮助程序始终返回游标。

除了前两个示例演示命令语法外，此页面中的示例都使用db.collection.aggregate()帮助器。

使用多阶段管道聚合数据

集合articles包含以下文档：

{
   _id: ObjectId("52769ea0f3dc6ead47c9a1b2"),
   author: "abc123",
   title: "zzz",
   tags: [ "programming", "database", "mongodb" ]
}

下面的示例对articles集合执行aggregate操作，以计算出现在该集合中的tags数组中每个不同元素的计数。

db.runCommand( {
   aggregate: "articles",
   pipeline: [
      { $project: { tags: 1 } },
      { $unwind: "$tags" },
      { $group: { _id: "$tags", count: { $sum : 1 } } }
   ],
   cursor: { }
} )

在mongo shell 中，此操作可以使用db.collection.aggregate()帮助器，如下所示：

db.articles.aggregate( [
   { $project: { tags: 1 } },
   { $unwind: "$tags" },
   { $group: { _id: "$tags", count: { $sum : 1 } } }
] )

在 Management 数据库上使用$ currentOp

以下示例在 admin 数据库上运行具有两个阶段的管道。第一阶段运行$currentOp操作，第二阶段过滤该操作的结果。

db.adminCommand( {
   aggregate : 1,
   pipeline : [ {
      $currentOp : { allUsers : true, idleConnections : true } }, {
      $match : { shard : "shard01" }
      }
   ],
   cursor : { }
} )

返回有关汇总操作的信息

以下聚合操作将可选字段explain设置为true，以返回有关聚合操作的信息。

db.orders.aggregate([
      { $match: { status: "A" } },
      { $group: { _id: "$cust_id", total: { $sum: "$amount" } } },
      { $sort: { total: -1 } }
   ],
   { explain: true }
)

使用外部排序汇总数据

聚合管道阶段具有最大内存使用限制。要处理大型数据集，请将allowDiskUse选项设置为true以启用将数据写入临时文件，如以下示例所示：

db.stocks.aggregate( [
      { $project : { cusip: 1, date: 1, price: 1, _id: 0 } },
      { $sort : { cusip : 1, date: 1 } }
   ],
   { allowDiskUse: true }
)

汇总指定批次大小的数据

要指定“初始”批处理大小，请在cursor字段中指定batchSize，如以下示例所示：

db.orders.aggregate( [
      { $match: { status: "A" } },
      { $group: { _id: "$cust_id", total: { $sum: "$amount" } } },
      { $sort: { total: -1 } },
      { $limit: 2 }
   ],
   { cursor: { batchSize: 0 } }
)

{batchSize: 0 }文档仅指定“初始”批处理大小的大小。与其他 MongoDB 游标一样，为OP_GET_MORE操作指定后续批处理大小。 batchSize或0表示第一批为空，如果您要快速获取游标或失败消息而又不做大量服务器端工作，则它很有用。

指定排序规则

3.4 版的新功能。

Collation允许用户为字符串比较指定特定于语言的规则，例如字母大写和重音符号的规则。

集合myColl具有以下文档：

{ _id: 1, category: "café", status: "A" }
{ _id: 2, category: "cafe", status: "a" }
{ _id: 3, category: "cafE", status: "a" }

以下聚合操作包括Collation选项：

db.myColl.aggregate(
   [ { $match: { status: "A" } }, { $group: { _id: "$category", count: { $sum: 1 } } } ],
   { collation: { locale: "fr", strength: 1 } }
);

有关整理字段的说明，请参见Collation Document。

提示索引

3.6 版的新功能。

创建包含以下文档的集合foodColl：

db.foodColl.insert([
   { _id: 1, category: "cake", type: "chocolate", qty: 10 },
   { _id: 2, category: "cake", type: "ice cream", qty: 25 },
   { _id: 3, category: "pie", type: "boston cream", qty: 20 },
   { _id: 4, category: "pie", type: "blueberry", qty: 15 }
])

创建以下索引：

db.foodColl.createIndex( { qty: 1, type: 1 } );
db.foodColl.createIndex( { qty: 1, category: 1 } );

以下聚合操作包括hint选项，以强制使用指定的索引：

db.foodColl.aggregate(
   [ { $sort: { qty: 1 }}, { $match: { category: "cake", qty: 10  } }, { $sort: { type: -1 } } ],
   { hint: { qty: 1, category: 1 } }
)

覆盖默认读取问题

要覆盖默认的阅读关注级别"local"，请使用readConcern选项。 getMore命令使用在原始aggregate命令中指定的readConcern级别。

对副本集的以下操作指定read concern到"majority"来读取已确认已写入大多数节点的数据的最新副本。

db.restaurants.aggregate(
   [ { $match: { rating: { $lt: 5 } } } ],
   { readConcern: { level: "majority" } }
)

为确保单个线程可以读取其自己的写入，请对副本集的主数据库使用"majority"读取关注和"majority"写入关注。