Mongoose 如何监听集合变化

Question

我需要构建一个 mongo updater 进程来将 mongodb 数据下载到本地物联网设备（配置数据等）

我的目标是在固定的时间间隔内（例如 1 分钟）观察一些 mongo 集合。如果我更改了收藏（删除、插入或更新），我会将完整收藏下载到我的设备上。集合不会超过几百个简单的记录，所以下载的数据不会很多。

是否有任何机制可以找出自上次池以来集合已更改？在这种情况下应该使用哪些 mongo 功能？

Answer 1

要监听 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', ...}

注意：此功能仅在 MongoDB副本集上可用

有关更多信息，请参阅猫鼬模型文档：

如果要侦听数据库的更改，请使用Connection.watch.

有关更多信息，请参阅猫鼬连接文档

这些功能监听更改事件从MongoDB的更改流为V3.6的