出现"k8s 运算符中的 golang 错误：对象已被更改"

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《出现"k8s 运算符中的 golang 错误：对象已被更改"》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

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
    }

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《出现"k8s 运算符中的 golang 错误：对象已被更改"》文章吧，也可关注golang学习网公众号了解相关技术文章。