如何使用 golang 客户端从 Kubernetes 中驱逐或删除 pod

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《如何使用 golang 客户端从 Kubernetes 中驱逐或删除 pod》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我想使用 client-go 包从 kubernetes 节点逐出所有 pod。与 kubectl 排水 类似。可能会忽略 kube-system 命名空间 pod。

我通过以下方式从节点获取了 pod 列表：

func evictNodePods(nodeInstance string, client *kubernetes.Clientset) {

    pods, err := client.CoreV1().Pods("").List(metav1.ListOptions{
        FieldSelector: "spec.nodeName=" + nodeInstance,
    })

    if err != nil {
        log.Fatal(err)
    }
    for _, i := range pods.Items {
        if i.Namespace == "kube-system" {
            continue
        } else {
            //evict
        }
    }
}

但我不清楚如何发送 post 请求来驱逐给定节点实例上的 pod

解决方案

删除 pod：

err := client.corev1().pods(i.namespace).delete(i.name, metav1.deleteoptions{})
if err != nil {
  log.fatal(err)
}

如果您将client-go升级到最新版本，还需要添加context作为参数。

err := client.corev1().pods(i.namespace).delete(context.todo(), i.name, metav1.deleteoptions{})
if err != nil {
  log.fatal(err)
}

虽然 delete 可能在大多数情况下都可以工作，但它并不能保证新的 pod 不会被调度到同一节点上。以下是实际处理此问题的方法：

对该节点进行污染，使其不可调度，从而将该节点移出调度池。

import (
  "context"

  "k8s.io/client-go/kubernetes"
  meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func cordonnode(client *kubernetes.clientset, name string) error {
  # fetch node object
  node, err := client.corev1().nodes().get(context.todo(), name, meta_v1.getoptions{})

  if err != nil {
    return err
  }

  node.spec.unschedulable = true

  # update the node
  _, err = client.corev1().nodes().update(context.todo(), node, meta_v1.updateoptions{})

  return err
}

现在您有两个选择：

• 在节点上添加 noexecute 的污点，kubelet 将为您从该节点驱逐所有工作负载。但是，容忍这种污点的 pod 仍将继续在节点上运行。

import (
  "context"

  "k8s.io/client-go/kubernetes"
  meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  v1 "k8s.io/api/core/v1"
)

func taintnode(client *kubernetes.clientset, name string) error {
  # fetch node object
  node, err := client.corev1().nodes().get(context.todo(), name, meta_v1.getoptions{})

  node.spec.taints = append(node.spec.taints, v1.taint{
    key: "somekey"
    value: "somevalue"
    effect: v1.tainteffectnoexecute
  })

  # update the node
  _, err = client.corev1().nodes().update(context.todo(), node, meta_v1.updateoptions{})

  return err
}

• 单独逐出该节点上运行的工作负载 pod。

import (
  "context"

  "k8s.io/client-go/kubernetes"
  meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  policy "k8s.io/api/policy/v1beta1"
)

func EvictPod(client *kubernetes.Clientset, name, namespace string) error {
  return client.PolicyV1beta1().Evictions(namespace).Evict(context.TODO(), &policy.Eviction{
        ObjectMeta: meta_v1.ObjectMeta{
            Name:      name,
            Namespace: namespace,
        }
}

到这里，我们也就讲完了《如何使用 golang 客户端从 Kubernetes 中驱逐或删除 pod》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！