Go实现MongoDB Watch无实际变更触发问题及条件更新问询

我用Go语言实现了一个监听MongoDB集合变更的WebSocket服务，同时有一个定时函数会执行以下更新操作：

_, e := alertsCollection.UpdateOne(ctx, bson.M{"alert.fingerprint": alert.Fingerprint}, bson.M{"$set": bson.M{"alert": *alert}}, opt)

同时通过Watch监听集合变更：

watch, err := alertsCollection.Watch(ctx, []bson.M{})
logError(err)
for watch.Next(ctx) {
    if e := watch.Decode(&alert); e != nil {
        log.Errorf("error decoding: %s", e)
    }
    resp, e := json.Marshal(alert)
    logError(e)
    logError(conn.WriteMessage(1, resp))
}

目前功能正常，但即使文档没有实际变更，Watch仍然会触发事件，日志里能看到重复的update操作记录，字段内容完全一致。请问有没有办法让更新只在字段真正变化时执行？

1. 让UpdateOne仅在数据实际变化时执行 #

直接修改UpdateOne的查询条件，加入数据差异判断，只有当目标文档的alert内容和要更新的内容不一致时，才执行更新操作。

可以用$ne操作符对比整个alert对象（适用于结构简单、可直接用MongoDB对象比较的场景）：

// 扩展查询条件：匹配fingerprint，且alert内容不等于要更新的内容
filter := bson.M{
    "alert.fingerprint": alert.Fingerprint,
    "alert": bson.M{"$ne": *alert},
}
_, e := alertsCollection.UpdateOne(ctx, filter, bson.M{"$set": bson.M{"alert": *alert}}, opt)

如果alert包含嵌套字段或数组，直接对比整个对象可能有精度问题，也可以先查询当前文档，在代码层面对比差异后再决定是否更新：

var existingDoc YourAlertDocumentStruct
err := alertsCollection.FindOne(ctx, bson.M{"alert.fingerprint": alert.Fingerprint}).Decode(&existingDoc)
if err != nil && err != mongo.ErrNoDocuments {
    logError(err)
    return
}
// 代码层面对比现有alert和新alert是否有差异
if !reflect.DeepEqual(existingDoc.Alert, *alert) {
    _, e := alertsCollection.UpdateOne(ctx, bson.M{"alert.fingerprint": alert.Fingerprint}, bson.M{"$set": bson.M{"alert": *alert}}, opt)
    logError(e)
}

注意：这种方式要考虑并发更新冲突，可配合version字段实现乐观锁，避免多进程同时修改导致的问题。

2. 在Watch监听中过滤无变更的事件 #

如果无法完全避免无意义的更新操作，也可以在监听端过滤掉没有实际字段变更的事件：

watch, err := alertsCollection.Watch(ctx, []bson.M{})
logError(err)
for watch.Next(ctx) {
    var changeEvent struct {
        OperationType    string                 `bson:"operationType"`
        UpdateDescription struct {
            UpdatedFields map[string]interface{} `bson:"updatedFields"`
        } `bson:"updateDescription"`
        Alert YourAlertStruct `bson:"fullDocument"`
    }
    if e := watch.Decode(&changeEvent); e != nil {
        log.Errorf("error decoding: %s", e)
        continue
    }
    // 如果是update操作且没有更新任何字段，跳过发送
    if changeEvent.OperationType == "update" && len(changeEvent.UpdateDescription.UpdatedFields) == 0 {
        continue
    }
    // 处理并发送WebSocket消息
    resp, e := json.Marshal(changeEvent.Alert)
    logError(e)
    logError(conn.WriteMessage(1, resp))
}

通过检查updateDescription.updatedFields的长度，就能过滤掉那些没有实际字段变更的update事件。

内容的提问来源于stack exchange，提问作者Brandon Kauffman