GoLang 中用 MongoDB Watch 监听指定字段的变化

饶文津

发布于 2020-05-31 15:53:46

2K0

发布于 2020-05-31 15:53:46

文章被收录于专栏：饶文津的专栏

需要 MongoDB 3.6 及以上, 需要 ReplicaSet 模式。监听一个字段的变化：

func watch(coll *mongo.Collection) {
	match := bson.D{{"operationType", "update"},
		{"updateDescription.updatedFields.name", bson.D{{"$exists", true}}}}
	coll.Watch(context.Background(), mongo.Pipeline{{{"$match", match}}},
		options.ChangeStream().SetFullDocument(options.UpdateLookup))
}

监听两个字段的变化：

func watch(coll *mongo.Collection) {
	match := bson.D{
                {"operationType", "update"},
		{"$or", bson.A{
			bson.D{{"updateDescription.updatedFields.name", 
                                bson.D{{"$exists", true}},
                        }},
			bson.D{{"updateDescription.updatedFields.age", 
                                bson.D{{"$exists", true}},
                        }},
                }}

	coll.Watch(context.Background(), mongo.Pipeline{{{"$match", match}}},
		options.ChangeStream().SetFullDocument(options.UpdateLookup))
}

任意一个变化，用$or ，都变化，用$and。注意 bson.A 里面是 bson.D。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019-09-11 ，如有侵权请联系 cloudcommunity@tencent.com 删除

mongodb