MongoDB聚合操作：$changeStream

本文介绍: $changeStream返回集合、数据库或整个群集上的Change Stream游标。必须在聚合管道的第一阶段使用。

返回集合、数据库或整个群集上的Change Stream游标。必须在聚合管道的第一阶段使用。

{
  $changeStream: {
    allChangesForCluster: <boolean>,
    fullDocument: <string>,
    fullDocumentBeforeChange: <string>,
    resumeAfter: <int>
    showExpandedEvents: <boolean>,
    startAfter: <document>
    startAtOperationTime: <timestamp>
  }
}

可选：设置Change Stream是否包括群集中的所有更改。可能只能在管理数据库中打开。

可选：指定update操作修改时，更改通知是否包含完整文档的副本。

在部分更新的情况下，更改通知还会提供更改说明。

包括更改前的完整文档。该字段接受以下值：

指定一个恢复标记作为更改流的逻辑起点。不能与 startAfter 或 startAtOperationTime 字段一起使用。

指定一个恢复标记作为更改流的逻辑起点。不能与 resumeAfter 或 startAtOperationTime 字段一起使用。

指定一个时间作为更改流的逻辑起点。不能与 resumeAfter 或 startAfter 字段一起使用。

var cur = db.names.aggregate( [
   { $changeStream: {} }
] )

运行cur打开光标。

当Change Stream检测到更改时，next()方法会返回更改事件通知。例如，在运行cur.next() 之后，MongoDB 会返回与下面类似的文档：

{
   "_id": {
      _data: "8262E2EE54000000022B022C0100296E5A100448E5E3DD01364019AE8FE8C6859527E046645F6964006462E2EE54C8756C0D5CF6F0720004"
   },
   "operationType": "insert",
   "clusterTime": Timestamp({ t: 1659039316, i: 2 }),
   "wallTime": ISODate("2022-07-28T20:15:16.148Z"),
   "fullDocument": {
      "_id": ObjectId("62e2ee54c8756c0d5cf6f072"),
      "name": "Walker Percy"
   },
   "ns": {
      "db": "test",
      "coll": "names"
   },
   "documentKey": { _id: ObjectId("62e2ee54c8756c0d5cf6f072") }
}