卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章35573本站已运行397

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

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 Regexp ReplaceAllString 中发现错误?
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏