db.watch()（mongosh方法）

定义

db.watch( pipeline, options )

仅适用于副本集和分片集群

打开变更流游标，以便数据库报告其所有非 system 集合的情况。

Parameter	类型	说明
pipeline	阵列	可选。Aggregation Pipeline 由以下一个或多个聚合阶段组成： $addFields $match $project $replaceRoot $replaceWith $redact $set $unset 指定用于筛选/修改变更事件输出的管道。 从 MongoDB 4.2 开始，如果变更流聚合管道修改了事件的 _id 字段，则变更流会引发异常。
options	文档	可选。用于修改 db.watch() 行为的其他选项。

options 文档可包含以下字段和值：

字段	类型	说明
resumeAfter	文档	可选。指定一个恢复令牌作为变更流的逻辑起点。无法用于在 invalidate 事件之后恢复变更流。 resumeAfter 与 startAfter 和 startAtOperationTime 互斥。
startAfter	文档	可选。指定一个恢复令牌作为变更流的逻辑起点。与 resumeAfter 不同，startAfter 可在出现 invalidate 事件之后通过创建新的变更流来恢复通知。 startAfter 与 resumeAfter 和 startAtOperationTime 互斥。
fullDocument	字符串	可选。默认情况下，db.watch() 返回通过更新操作修改的字段的增量，而不是整个更新后的文档。 将 fullDocument 设置为 "updateLookup"，以指示 db.watch() 查找更新后的文档的最新多数提交版本。db.watch() 除了返回 updateDescription 增量以外，还会返回一个包含文档查询的 fullDocument 字段。 从 MongoDB 6.0 开始，您可将 fullDocument 设为： "whenAvailable" 在插入、替换或更新文档之后输出文档后像（如果有）。 "required" 在插入、替换或更新文档之后输出文档后像。如果后像不可用，则引发错误。
fullDocumentBeforeChange	字符串	可选。默认值为 "off"。 从 MongoDB 6.0 开始，您可以使用新的 fullDocumentBeforeChange 字段并将其设置为： "whenAvailable" 在替换、更新或删除文档之前输出文档前像（如果有）。 "required" 在替换、更新或删除文档之前输出文档前像。如果前像不可用，则引发错误。 "off" 抑制文档前像。"off" 是默认值。
batchSize	int	可选。指定从 MongoDB 集群响应的每个批次中返回的变更事件的最大数量。 功能与 cursor.batchSize() 相同。
maxAwaitTimeMS	int	可选。在返回空批次之前，服务器等待新数据更改以报告给变更流游标的最长时间（以毫秒为单位）。 默认值为 1000 毫秒。
collation	文档	可选。传递排序规则文档以指定变更流游标的排序规则。 如果省略，则默认为 simple 二进制比较。
startAtOperationTime	时间戳	可选。变更流的起点。如果指定的起点在过去，它必须在 oplog 的时间范围内。要检查 oplog 的时间范围，请参阅 rs.printReplicationInfo()。 startAtOperationTime 与 resumeAfter 和 startAfter 互斥。

返回：	改变事件文档上的 游标。有关改变事件文档的示例，请参阅改变流事件。

提示

db.collection.watch() 和 Mongo.watch()

兼容性

此方法可用于以下环境中托管的部署：

• MongoDB Atlas：用于云中 MongoDB 部署的完全托管服务

• MongoDB Enterprise：基于订阅、自我管理的 MongoDB 版本

• MongoDB Community：源代码可用、免费使用且可自行管理的 MongoDB 版本

可用性

行为

• 您不能在 admin、local 或 config 数据库中运行 db.watch()。

• db.watch() 仅通知持续到大多数数据承载节点的数据更改。

• 变更流游标保持打开状态，直到出现以下任一情况：

  • 游标已明确关闭。

  • 发生失效事件；例如删除或重命名集合。

  • 与MongoDB 部署的连接关闭或超时。有关更多信息，请参阅行为。

  • 如果部署是分片集群，则分片删除可能会导致打开的变更流游标关闭，而关闭的变更流游标可能无法完全恢复。

• 您可以为不存在的数据库运行 db.watch()。但是，一旦创建了数据库并且删除了该数据库，变更流游标就会关闭。

访问控制

使用访问控制来运行时，用户必须对数据库资源具有 find 和 changeStream 特权动作。换言之，用户必须具有能授予以下特权的角色：

{ resource: { db: <dbname>, collection: "" }, actions: [ "find", "changeStream"] }

内置 read 角色提供了相应的特权。

游标迭代

MongoDB 提供多种在游标上迭代的方法。

cursor.hasNext() 方法会阻塞并等待下一个事件。要监控 watchCursor 游标并迭代事件，请使用 hasNext()，如下所示：

while (!watchCursor.isClosed()) {
   if (watchCursor.hasNext()) {
     firstChange = watchCursor.next();
     break;
   }
}

该 cursor.tryNext() 方法为非阻塞式。要监控 watchCursor 游标并迭代事件，请使用 tryNext()，如下所示：

while (!watchCursor.isClosed()) {
  let next = watchCursor.tryNext()
  while (next !== null) {
    printjson(next);
    next = watchCursor.tryNext()
  }
}

例子

mongosh 中的以下操作在 hr 数据库中打开变更流游标。返回的游标报告该数据库中所有非 system 集合的数据变更。

watchCursor = db.getSiblingDB("hr").watch()

迭代游标以检查是否存在新事件。使用 cursor.isClosed() 方法和 cursor.tryNext() 方法，确保循环仅在变更流游标已关闭且最新批次中没有剩余对象时才退出：

while (!watchCursor.isClosed()) {
  let next = watchCursor.tryNext()
  while (next !== null) {
    printjson(next);
    next = watchCursor.tryNext()
  }
}

如需变更流输出的完整文档，请参阅 变更流事件。