在 mongo shell 中创建 mongo 更改流

Question

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

Answer 1

db.collection.watch命令打开一个change stream cursor.

例如：

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

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

更多细节in the docs。

在 mongo shell 中创建 mongo 更改流

Create mongo change stream in the mongo shell

mongodb

changestream

mongodb-3.6