golang 在 k8s 运算符上出现错误“对象已被修改”

php小编草莓在探索使用golang开发kubernetes运算符时，遇到了一个常见的错误：“对象已被修改”。这个错误通常发生在多个goroutine同时修改同一个对象时，导致数据不一致或竞争条件。在本文中，我们将探讨这个错误的原因和解决方案，帮助开发者更好地理解和处理类似的问题。

问题内容

k8s 操作符上出现“对象已被修改”错误

import "sigs.k8s.io/controller-runtime"

关于这种错误有很多讨论。主要答案是“发生此问题是因为当我尝试更新时我有旧版本的对象。” 但我也有一些问题。在我的操作员中，对于某些场景，我需要在一次“协调”调用期间更新 pod 的注释 2 次。当然，我经常收到“对象已被修改”的错误。

问题：我想知道 'r.Get()' 和 'r.Update()' 在哪里获取/更新对象？来自本地缓存，还是 API 服务器？

1: 我认为 'r.Get()' 是从 'cache' 获取对象，而 'r.Update()' 是更新对象到缓存，对吗？如果是这样，为什么我会收到此错误？如果 pod 对象由于操作员以外的原因而更改，我将无法在当前“协调”期间永远更新我的 pod 对象？（由于缓存对象是本地的，它已经与 API 服务器不同步。）为什么要“重试”有的时候能获取到最新的对象吗？

import "sigs.k8s.io/controller-runtime"

var pod corev1.Pod
if err := r.Get(ctx, req.NamespacedName, &pod); err != nil {
    if !apierrors.IsNotFound(err) {
        log.Error(err, "unable to get pod")
        return ctrl.Result{}, err
    }
}

if err := r.Update(ctx, &pod); err != nil {
    log.Error(err, "unable to update chaosctl status")
    return ctrl.Result{}, err
}

2：如果'r.Get()'是从API服务器获取对象，并且'r.Update()'也更新API服务器。为什么我需要重试更新对象？

解决方法

当您在 Kubernetes 控制器中使用 r.Get() 和 r.Update() 时，与 API 服务器的交互涉及本地缓存和 API 服务器本身。

r.Get():

r.Get() 函数从本地缓存中检索对象（如果存在）；否则，它会从 API 服务器获取它。 如果该对象存在于本地缓存中，则立即返回。如果没有，则向API服务器请求获取该对象，并将获取到的对象存储在本地缓存中以供后续使用。 r.Update():

r.Update() 函数会更新本地缓存和 API 服务器中的对象。 如果该对象自最初检索以来已在本地缓存中被修改，则对 API 服务器的更新操作可能会失败并出现“冲突”错误。当缓存中对象的版本与 API 服务器上的版本不匹配时，就会发生这种情况，表明其他人在此期间修改了该对象。

可以采取策略来处理它 -

1. 乐观并发控制（OCC）： - 更新之前的版本匹配。
2. retry -

retryErr := retry.RetryOnConflict(retry.DefaultRetry, func() error {
        return r.Update(ctx, pod)
    })
    if retryErr != nil {
        return retryErr
    }

以上就是golang 在 k8s 运算符上出现错误“对象已被修改”的详细内容，更多请关注编程网其它相关文章！