我需要构建一个 mongo updater 进程来将 mongodb 数据下载到本地物联网设备(配置数据等)
我的目标是在固定的时间间隔内(例如 1 分钟)观察一些 mongo 集合。如果我更改了收藏(删除、插入或更新),我会将完整收藏下载到我的设备上。集合不会超过几百个简单的记录,所以下载的数据不会很多。
是否有任何机制可以找出自上次池以来集合已更改?在这种情况下应该使用哪些 mongo 功能?
最佳答案
要监听 MongoDB 集合的更改,请设置 Mongoose Model.watch
.
const PersonModel = require('./models/person')
const personEventEmitter = PersonModel.watch()
personEventEmitter.on('change', change => console.log(JSON.stringify(change)))
const person = new PersonModel({name: 'Thabo'})
person.save()
// Triggers console log on change stream
// {_id: '...', operationType: 'insert', ...}
Note: This functionality is only available on a MongoDB Replicaset
见 Mongoose Model Docs更多:
如果您想收听 的更改数据库 , 使用
Connection.watch
.见 Mongoose Connection Docs更多
这些函数监听 Change Events来自 MongoDB Change Streams从 v3.6 开始
关于mongodb - Mongoose 如何监听集合变化,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48269827/