2

MongoDB在其 3.6 版本中引入了变更流。
我想在我的代码中实现 mongo 更改流,并想了解它是如何工作的。我将使用 java 驱动程序来实现,这很清楚。但我想知道是否有任何方法可以在 mongo shell 中打开更改流?在这方面找不到太多资源。

4

1 回答 1

5

db.collection.watch命令打开achange 流游标

例如:

watchCursor = db.getSiblingDB("data").sensors.watch(
   [
      { $match : {"operationType" : "insert" } }
   ]
)

while (!watchCursor.isExhausted()){
   if (watchCursor.hasNext()){
      print(tojson(watchCursor.next()));
   }
}

文档中有更多详细信息。

于 2018-01-17T11:55:14.290 回答