MongoDB updateOne() 返回 "modifiedCount": 1 对于同一文档的同时更新调用

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《MongoDB updateOne() 返回 "modifiedCount": 1 对于同一文档的同时更新调用》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我们正在尝试使用 updateone() 更新文档。过滤器识别文档，我们使用 $set 更新文档的属性。此更新作业由 cron 作业每分钟触发一次。

比如说，原始文档是{_id: "user1001", status: "inactive"}。我们通过使用过滤器 {_id: "user1001", status: "inactive"} 调用 updateone() 并将状态字段更新为 {"$set":{status:"active"}} 来更新它。我们查看 modifiedcount 的结果值，并期望它为 1，表明 updateone() 操作成功。然后这会触发下游作业。

该应用程序正在 kubernetes 中运行，我们已经对其进行了扩展。当我们在负载下测试系统时，会从两个不同的 pod 对具有相同过滤器的同一文档同时进行两次 updateone() 调用，并且都返回 modifiedcount 为 1。

我们预计 pod 中的一个 modifiedcount 为 1，另一个为 0。但对于某些文档，我们看到了这个结果。

参考示例代码

// cron job that calls update() every minute

func update(){
  filter := bson.D{{"_id", "USER1001"}, {"status", "INACTIVE"}}
  result, err := collection.UpdateOne(context.Background(), filter, bson.M{"$set": bson.M{"status": "ACTIVE"}})
  
  if result.ModifiedCount != 1 {
    // no update done
  } else {
    // call downstream jobs
  }
}

我们从应用程序 pod 中获得的示例日志行

• pod-1

[2020-11-20 17:30:58.610518875 +0000 utc] [debug] [myjob-7dc8b78bcf-c4677] update() :: 更新结果 :: user1001 / 匹配=1 / 修改=1

• pod-2

[2020-11-20 17:30:58.409843674 +0000 utc] [debug] [myjob-7dc8b78bcf-jd7m8] update() :: 更新结果 :: user1001 / 匹配=1 / 修改=1

问题是 -

1. 还有其他人见过这种行为吗？
2. 什么可能导致此问题？

其他信息，

• 应用程序采用 go 语言
• mongo 是 4.4 并且
• 我们正在使用最新的 mongo-driver for go。
• cron 作业每分钟运行一次，而不是一分钟就运行一次。意思就是，
  • pod-1 可能会在以下位置运行：
    • 10:00:23
    • 10:01:23
    • 10:02:23 等
  • pod-2 可能会在以下位置运行：
    • 10:00:35
    • 10:01:35
    • 10:02:35 等

解决方案

如果您先阅读此文档，发现它处于非活动状态，然后决定激活它，这是您必须处理的常见竞争条件。另一个进程执行相同的操作，然后都更新文档。

有一些方法可以防止这种情况发生。 Mongodb 文档级操作是原子的，因此针对您的情况最简单的解决方案是将过滤器更改为 {_id:"USER1001","status":"INACTIVE"} 以确保文档在更新时处于非活动状态。然后，尽管多个节点可能会尝试更新该文档，但只有一个节点会成功更新该文档。

今天关于《MongoDB updateOne() 返回 "modifiedCount": 1 对于同一文档的同时更新调用》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！