mongodb - 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', ...}

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 开始