这两天在写一个功能, 使用的是mongodb, 主语言是golang, 库是mongo-driver 其中有个需求,当时数据库的某个字段发生改变的时候,要能watch (监控) 到. 这里先上一下 可以触发watch的代码:(由于编码里没有使用golang的格式,所以下边代码很乱)
func (m *Mongo) Watch(table, operation string, fields []string) (db.Cursor, error) { coll, err := m.collection(table) if err != nil { return nil, err } ctx, _ := context.WithTimeout(context.Background(), m.cfg.Timeout) match := bson.D{{"operationType", operation}} if len(fields) > 0 { or := bson.A{} for _, field := range fields { or = append(or, bson.D{{ "updateDescription.updatedFields." + field, bson.D{{"$exists", true}}}}) } match = append(match, bson.E{"$or", or}) } stream, err := coll.Watch(ctx, mongo.Pipeline{{{"$match", match}}}, options.ChangeStream().SetFullDocument(options.UpdateLookup)) if err != nil { return nil, err } return &Cursor{ChangeStream: stream}, nil}我大概介绍一下这个功能:
先说参数 table 是具体的表名, operation 是触发的方式 比如 update delete insert, fields里是具体当前这个表里要触发的字段,比如有个name字段被update了,所以就要触发watch. 所以语句代码也是围绕这个来说的, 里边的$or 是代表任意一个字段发生变更都会触发, 如果必须全部字段 可以用 $and.
好了 前沿说了很多了,来说说我遇到的坑. 当我在业务代码中 进行 update 的时候, watch被很好的触发了, 但当我使用mongo的gui工具robot3的时候,竟然奇迹的发现,我的watch事件没有发生变更. 这使我很头疼, 百度了很久没有找到, 又去google了一段时间,也没有找到. 后来在朋友的帮助下,找到了答案: 如果是robot3 修改, 需要吧watch事件里的update替换成replace(当然 如果需要指定某些字段的话,还需要作微调,这里我就不细说了.) 总之 结论就是当使用gui 操作 mongo的时候, 我们使用watch 不能监听update, 而是replace. 不过一般来说我们都是在代码里操作,所以 update监听还是首选的,不过这里分享出这一经历.希望会对大家有所帮助
··································
欢迎关注课程：
《Django入门到进阶-更适合Python小白的系统课程》