如何在k8s中获取StatefulSet的最新更新时间

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《如何在k8s中获取StatefulSet的最新更新时间》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

例如，我知道您可以使用kubectl获取部署的lastupdatetime：

kubectl get deploy  -o jsonpath={.status.conditions[1].lastupdatetime}

或者通过client-go：

func deploymentCheck(namespace string, clientset *kubernetes.Clientset) bool {
    // get the deployments in the namespace
    deployments, err := clientset.AppsV1().Deployments(namespace).List(context.TODO(), metav1.ListOptions{})
    if errors.IsNotFound(err) {
        log.Fatal("\nNo deployments in the namespace", err)
    } else if err != nil {
        log.Fatal("\nFailed to fetch deployments in the namespace", err)
    }

    var dptNames []string
    for _, dpt := range deployments.Items {
        dptNames = append(dptNames, dpt.Name)
    }
    // check the last update time of the deployments
    for _, dpt := range deployments.Items {
        lastUpdateTime := dpt.Status.Conditions[1].LastUpdateTime
        dptAge := time.Since(lastUpdateTime.Time)
        fmt.Printf("\nDeployment %v age: %v", dpt.Name, dptAge)
    }
}

statefulset 的 lastupdatetime := dpt.status.conditions[1].lastupdatetime 的等效项似乎不存在。

那么，如何获取statefulset的lastupdatetime呢？

正确答案

我注意到，在某人编辑给定资源后，唯一发生变化的是该资源的lastappliedconfiguration、generation 和observedgeneration。因此，我将它们存储在列表中：

for _, deployment := range deployments.items {
        deploymentnames = append(deploymentnames, deployment.name)
        lastappliedconfig := deployment.getannotations()["kubectl.kubernetes.io/last-applied-configuration"]

        lastappliedconfigs = append(lastappliedconfigs, lastappliedconfig)
        generations = append(generations, deployment.generation)
        observedgenerations = append(observedgenerations, deployment.status.observedgeneration)
    }

完整功能如下：

func deploymentcheck(namespace string, clientset *kubernetes.clientset) ([]string, []string, []int64, []int64) {

    var deploymentnames []string
    var lastappliedconfigs []string
    var generations []int64
    var observedgenerations []int64

    deployments, err := clientset.appsv1().deployments(namespace).list(context.todo(), metav1.listoptions{})
    if errors.isnotfound(err) {
        log.print("no deployments in the namespace", err)
    } else if err != nil {
        log.print("failed to fetch deployments in the namespace", err)
    }

    for _, deployment := range deployments.items {
        deploymentnames = append(deploymentnames, deployment.name)
        lastappliedconfig := deployment.getannotations()["kubectl.kubernetes.io/last-applied-configuration"]

        lastappliedconfigs = append(lastappliedconfigs, lastappliedconfig)
        generations = append(generations, deployment.generation)
        observedgenerations = append(observedgenerations, deployment.status.observedgeneration)
    }

    return deploymentnames, lastappliedconfigs, generations, observedgenerations
}

我使用所有这些信息来实例化一个名为 namespace 的结构，其中包含 k8s 命名空间可以拥有的所有主要资源。

然后，在给定时间后，我再次检查相同的命名空间并检查其资源是否有任何更改：

if !reflect.DeepEqual(namespace.stsLastAppliedConfig, namespaceCopy.stsLastAppliedConfig) {
...
}
else if !reflect.DeepEqual(namespace.stsGeneration, namespaceCopy.stsGeneration) {
...
}
else if !reflect.DeepEqual(namespace.stsObservedGeneration, namespaceCopy.stsObservedGeneration) {
...
}

因此，我发现的唯一解决方法是在给定时间后比较资源的配置，包括 statefulsets'。显然，对于某些资源，您无法获取有关其上次更新时间的任何信息。

我还发现lastupdatetime实际上并不可靠，因为它会将较小的集群更改理解为资源的更改。例如，如果集群轮换并杀死所有 pod，则 deployment 的 lastupdatetime 将更新其时间。那不是我想要的。我想检测用户对资源的更改，例如当有人应用编辑的 yaml 文件或运行 kubectl edit 时。

@hypperster，希望有帮助。

今天关于《如何在k8s中获取StatefulSet的最新更新时间》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！