请写k8s设置节点执行 drain 操作的api代码

以下是使用 Kubernetes Python API 客户端库设置节点执行 drain 操作的代码示例：

from kubernetes import client, config

# 加载 Kubernetes 配置文件
config.load_kube_config()

# 创建 Kubernetes API 客户端实例
v1 = client.CoreV1Api()

# 指定要进行 drain 操作的节点名称
node_name = "your-node-name"

# 创建 V1NodeDrain 对象，用于指定 drain 操作的参数
drain_spec = client.V1NodeDrain(delete_local_data=True, grace_period_seconds=60)

# 调用 V1NodeApi 对象的 evict_node 方法，在指定节点上执行 drain 操作
response = v1.evict_node(name=node_name, body=drain_spec)
print(response)

需要注意的是，执行 drain 操作需要具有相应的权限。如果你使用的是 kubeconfig 文件进行认证，需要确保文件中的用户具有执行 drain 操作的权限。否则，可以在创建 Kubernetes API 客户端实例时指定相应的认证信息。

相关问题

使用 Kubernetes go API 客户端库设置节点执行 drain 操作的代码示例

好的，请参考以下的代码示例：

package main

import (
	"context"
	"flag"
	"fmt"
	"log"
	"time"

	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
	"k8s.io/client-go/util/retry"
	"k8s.io/kubernetes/pkg/api/v1"
)

func main() {
	var kubeconfig string
	flag.StringVar(&kubeconfig, "kubeconfig", "", "Path to kubeconfig file")
	flag.Parse()

	// Loading kubeconfig file
	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
	if err != nil {
		log.Fatalf("Error building kubeconfig: %s", err.Error())
	}

	// Creating kubernetes clientset
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		log.Fatalf("Error creating kubernetes client: %s", err.Error())
	}

	// Node name to be drained
	nodeName := "node-1"

	// Fetching node with name 'nodeName'
	node, err := clientset.CoreV1().Nodes().Get(context.Background(), nodeName, v1.GetOptions{})
	if err != nil {
		log.Fatalf("Error getting node '%s': %s", nodeName, err.Error())
	}

	// Setting 'unschedulable' field of node to 'true'
	node.Spec.Unschedulable = true

	// Applying changes to node
	err = retry.RetryOnConflict(retry.DefaultRetry, func() error {
		_, updateErr := clientset.CoreV1().Nodes().Update(context.Background(), node, v1.UpdateOptions{})
		return updateErr
	})
	if err != nil {
		log.Fatalf("Error updating node '%s': %s", nodeName, err.Error())
	}

	// Waiting for all pods scheduled on the node to terminate
	for {
		pods, err := clientset.CoreV1().Pods("").List(context.Background(), v1.ListOptions{})
		if err != nil {
			log.Fatalf("Error listing pods: %s", err.Error())
		}

		// Checking if all pods are terminated
		allTerminated := true
		for _, pod := range pods.Items {
			if pod.Spec.NodeName == nodeName {
				allTerminated = false
				break
			}
		}

		if allTerminated {
			break
		}

		time.Sleep(5 * time.Second)
	}

	// Setting 'unschedulable' field of node to 'false'
	node.Spec.Unschedulable = false

	// Applying changes to node
	err = retry.RetryOnConflict(retry.DefaultRetry, func() error {
		_, updateErr := clientset.CoreV1().Nodes().Update(context.Background(), node, v1.UpdateOptions{})
		return updateErr
	})
	if err != nil {
		log.Fatalf("Error updating node '%s': %s", nodeName, err.Error())
	}

	fmt.Printf("Node '%s' drained successfully\n", nodeName)
}

这个程序将节点 "node-1" 设为不可调度状态（即执行 drain 操作），等待所有调度在该节点上的 Pod 终止，然后将节点设为可调度状态。注意，需要使用 RetryOnConflict 函数来避免更新期间的冲突。

k8s设置节点不可调度

如果你想要设置 Kubernetes 集群中的某个节点不可调度，可以通过以下步骤来实现：

1. 在 Kubernetes 集群中找到该节点的名称。

   kubectl get nodes

2. 标记该节点为不可调度。

   kubectl cordon <node_name>

3. 确认该节点已经被标记为不可调度。

   kubectl get nodes

这样，该节点就不会再接受新的 Pod 调度了。如果该节点上已经有正在运行的 Pod，它们将会继续运行。如果你想要从该节点上移除某个 Pod，可以使用以下命令：

kubectl drain <node_name>

这个命令会让该节点上的 Pod 自动迁移到其他节点上。待所有 Pod 迁移完成后，该节点就可以被从集群中删除了。