变更事件_MonogDB 中文网

在本页面

变更事件
insert 事件
update 事件
replace 事件
delete 事件
drop 事件
rename 事件
dropDatabase 事件
invalidate 事件

更改事件¶

以下文档表示变更流响应文档可以具有的所有可能的字段。

{
   _id : { <BSON Object> },
   "operationType" : "<operation>",
   "fullDocument" : { <document> },
   "ns" : {
      "db" : "<database>",
      "coll" : "<collection>"
   },
   "to" : {
      "db" : "<database>",
      "coll" : "<collection>"
   },
   "documentKey" : { "_id" : <value> },
   "updateDescription" : {
      "updatedFields" : { <document> },
      "removedFields" : [ "<field>", ... ]
   }
   "clusterTime" : <Timestamp>,
   "txnNumber" : <NumberLong>,
   "lsid" : {
      "id" : <UUID>,
      "uid" : <BinData>
   }
}

有些字段仅适用于某些操作，例如更新。下表描述了变更流响应文档中的每个字段：

领域	类型	描述
_ID	文献	与操作有关的元数据。作为行为`resumeToken` 的`resumeAfter`参数恢复的改变流时。复制 { "_data" : <BinData\|hex string> } 该`_data`类型取决于MongoDB的版本，在某些情况下，在变换流的开/恢复时间的功能兼容性版本（FCV）。有关详细信息，请参阅“ 恢复令牌”。
`operationType`	串	发生的操作类型。可以是以下任意值： `insert` `delete` `replace` `update` `drop` `rename` `dropDatabase` `invalidate`
`fullDocument`	文献	通过创建或修改文件`insert`，`replace`， `delete`，`update`操作（即CRUD操作）。对于`insert`和`replace`操作，这表示该操作创建的新文档。对于`delete`操作，此字段将被省略，因为文档不再存在。对于`update`操作，如果你配置的变换流本场只出现`fullDocument`设置为`updateLookup`。然后，此字段表示由更新操作修改的文档的最新多数提交版本。`updateDescription` 如果其他多数提交的操作在原始更新操作和完整文档查找之间修改了文档，则此文档可能与所描述的更改有所不同。
`ns`	文献	受事件影响的名称空间（数据库和/或集合）。
`ns.db`	串	数据库的名称。
`ns.coll`	串	集合的名称。对于`dropDatabase`操作，将省略此字段。
`to`	文献	如果为，则此文档显示集合的新名称。对于的所有其他值，将省略此文档。`operationType : renamensoperationType`
`to.db`	串	数据库的新名称。
`to.coll`	串	集合的新名称。
`documentKey`	文献	包含文档的`_id`由创建或修改的文件的`insert`， `replace`，`delete`，`update`操作（即CRUD操作）。对于分片集合，还显示文档的完整分片键。`_id`如果该字段已经是分片密钥的一部分，则不会重复该字段。
`updateDescription`	文献	描述由更新操作更新或删除的字段的文档。仅当`operationType`是时，此文档及其字段才会出现`update`。
`updateDescription.updatedFields`	文献	一个文档，其键对应于由更新操作修改的字段。每个字段的值对应于那些字段的新值，而不是导致新值的操作。
`updateDescription.removedFields`	数组	由更新操作删除的字段数组。
`clusterTime`	时间戳记	来自与事件相关联的oplog条目的时间戳。对于作为多文档事务的一部分发生的事件，关联的变更流通知将具有相同的`clusterTime`值，即事务提交的时间。在分片群集上，发生在不同分片上的事件可以具有相同的事件，`clusterTime`但与不同的事务相关联，甚至不与任何事务相关联。要确定事件的单个事务，你可以使用的组合`lsid`和`txnNumber`变化流事件文件内。版本4.0中的新功能。
`txnNumber`	长号	交易号。仅当操作是多文档事务的一部分时才存在。版本4.0中的新功能。
`lsid`	文献	与事务关联的会话的标识符。仅当操作是多文档事务的一部分时才存在。版本4.0中的新功能。

`insert`事件¶

以下示例说明了一个insert事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'insert',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   documentKey: {
      userName: 'alice123',
      _id: ObjectId("599af247bb69cd89961c986d")
   },
   fullDocument: {
      _id: ObjectId("599af247bb69cd89961c986d"),
      userName: 'alice123',
      name: 'Alice'
   }
}

该documentKey字段包括_id和userName 字段。这表示engineering.users集合已分片，并且在userName和上都有分片键_id。

该fullDocument文档表示插入时文档的版本。

`update`事件¶

以下示例说明了一个update事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'update',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   documentKey: {
      _id: ObjectId("58a4eb4a30c75625e00d2820")
   },
   updateDescription: {
      updatedFields: {
         email: 'alice@10gen.com'
      },
      removedFields: ['phoneNumber']
   }
}

以下示例说明了update使用选项打开的变更流的事件：fullDocument : updateLookup

复制

{
   _id: { < Resume Token > },
   operationType: 'update',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   documentKey: {
      _id: ObjectId("58a4eb4a30c75625e00d2820")
   },
   updateDescription: {
      updatedFields: {
         email: 'alice@10gen.com'
      },
      removedFields: ['phoneNumber']
   },
   fullDocument: {
      _id: ObjectId("58a4eb4a30c75625e00d2820"),
      name: 'Alice',
      userName: 'alice123',
      email: 'alice@10gen.com',
      team: 'replication'
   }
}

该fullDocument文档表示已更新文档的最新多数批准版本。该fullDocument文档可能与更新操作时的文档有所不同，具体取决于在更新操作和文档查找之间发生的交错多数授权操作的数量。

`replace`事件¶

以下示例说明了一个replace事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'replace',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   documentKey: {
      _id: ObjectId("599af247bb69cd89961c986d")
   },
   fullDocument: {
      _id: ObjectId("599af247bb69cd89961c986d"),
      userName: 'alice123',
      name: 'Alice'
   }
}

一个replace操作使用update命令，并且包括两个阶段：

使用documentKey和删除原始文档
使用相同的插入新文档 documentkey

在fullDocument一个的replace事件表示替换文件的插入后的文件。

`delete`事件¶

以下示例说明了一个delete事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'delete',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   documentKey: {
      _id: ObjectId("599af247bb69cd89961c986d")
   }
}

该fullDocument文档被省略，因为在更改流游标将delete事件发送到客户端时，该文档不再存在。

`drop`事件¶

版本4.0.1中的新功能。

一个drop在集合从数据库中删除发生的事件。以下示例说明了一个drop事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'drop',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   }
}

一个drop事件导致一个无效事件变革流张开攻击它的ns集合。

`rename`事件¶

版本4.0.1中的新功能。

一个rename在集合重命名发生的事件。以下示例说明了一个rename事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'rename',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering',
      coll: 'users'
   },
   to: {
      db: 'engineering',
      coll: 'people'
   }
}

一个rename事件导致一个无效事件的流变化对打开的ns集合或to集合。

`dropDatabase`事件¶

版本4.0.1中的新功能。

一个dropDatabase当数据库被丢弃发生的事件。以下示例说明了一个dropDatabase事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'dropDatabase',
   clusterTime: <Timestamp>,
   ns: {
      db: 'engineering'
   }
}

甲dropDatabase命令生成一个降事件产生之前对数据库中的每个收集dropDatabase数据库事件。

一个dropDatabase事件导致一个无效事件的流变化对打开的ns.db数据库。

`invalidate`事件¶

以下示例说明了一个invalidate事件：

复制

{
   _id: { < Resume Token > },
   operationType: 'invalidate',
   clusterTime: <Timestamp>
}

对于针对集合打开的变更流，影响监视的集合的放置事件，重命名事件或 dropDatabase事件导致无效事件。

对于针对数据库打开的变更流，影响受监视数据库的 dropDatabase事件导致 invalidate事件。

invalidate 事件关闭更改流游标。

resumeAfter在无效事件（例如，集合删除或重命名）关闭流之后，您不能用来恢复更改流。从MongoDB 4.2开始，您可以使用 startAfter在invalidate事件之后启动新的更改流。

MongoDB 中文手册

变更事件

更改事件¶

insert事件¶

update事件¶

replace事件¶

delete事件¶

drop事件¶

rename事件¶

dropDatabase事件¶

invalidate事件¶

`insert`事件¶

`update`事件¶

`replace`事件¶

`delete`事件¶

`drop`事件¶

`rename`事件¶

`dropDatabase`事件¶

`invalidate`事件¶