这两天在写一个功能, 使用的是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小白的系统课程》

  金职位 Python工程师2020版