Kubernetes API -获取特定节点上的Pod

vktxenjb  于 2023-06-05  发布在  Kubernetes
关注(0)|答案(6)|浏览(238)

阅读Kubernets文档,可以根据标签选择一定范围的pod。我想选择一个节点上的所有pod,但我不想在对应的节点上标记每个pod。
我是否缺少文档中的某些内容,或者无法按节点进行选择?
如果我这样做:

kubectl get pods \
--output=wide
--namespace=$NS \
--server=$SERVER | head

#=>

NAME   READY     STATUS             RESTARTS   AGE       NODE

这些头文件中的任何一个都可以用作选择器吗?如果是,如何使用kubectl?如何使用API?

0dxa2lsx

0dxa2lsx1#

正如在接受的答案中提到的,PR现在被合并,你可以按节点获取pod,如下所示:

kubectl get pods --all-namespaces -o wide --field-selector spec.nodeName=<node>
cedebl8k

cedebl8k2#

按nodeName排序Pod示例:

kubectl get pods -o wide --sort-by="{.spec.nodeName}"

使用标签过滤器获取节点上的Pod示例:

for n in $(kubectl get nodes -l your_label_key=your_label_value --no-headers | cut -d " " -f1); do 
    kubectl get pods --all-namespaces  --no-headers --field-selector spec.nodeName=${n} 
done

或按重新启动次数

kubectl get pods --sort-by="{.status.containerStatuses[:1].restartCount}"

使用--template标志按nodeName进行过滤的示例:

$ kubectl get nodes

NAME                         STATUS                     AGE
ip-10-0-90-30.ec2.internal   Ready                      2d
ip-10-0-90-35.ec2.internal   Ready                      2d
ip-10-0-90-50.ec2.internal   Ready,SchedulingDisabled   2d
ip-10-0-91-60.ec2.internal   Ready                      2d
ip-10-0-91-65.ec2.internal   Ready                      2d

$kubectl get pods --template '{{range .items}}{{if eq .spec.nodeName "ip-10-0-90-30.ec2.internal"}}{{.metadata.name}}{{"\n"}}{{end}}{{end}}'

filebeat-pezch
app-5xole
node-exporter-6kfs8
prometheus-0
sso-359976856-wu8zt
eoigrqb6

eoigrqb63#

您还可以使用以下命令查询a节点上的所有pod

kubectl get pods -o wide --all-namespaces | grep <YOUR-NODE>
wvmv3b1j

wvmv3b1j4#

kubectl describe node $NODE

将显示在$NODE上运行的所有非终止Pod。

o8x7eapl

o8x7eapl5#

你想要的东西在Kubernetes API服务器端支持如下:

curl --cacert ca.crt --cert apiserver.crt --key apiserver.key  https://<server>:<port>/api/v1/namespaces/<namespace>/pods?fieldSelector=spec.nodeName%3Dsomenodename

但是,kubectl中还没有内置字段选择器选项:https://github.com/kubernetes/kubernetes/pull/50140

bejyjqdl

bejyjqdl6#

我已经用Go Client完成了相同的过程,它揭示了CLI正在采取的一些快捷方式。

func doNodesHavePods(clientset *kubernetes.Clientset) error {
    nodeLabelSelector := "nodelabel=interesting_nodes"
    nodes, err := clientset.CoreV1().Nodes().List(metav1.ListOptions{LabelSelector: nodeLabelSelector})

    if err != nil {
        return err
    }

    nodeNames := []string{}
    for _, node := range nodes.Items {
        nodeNames = append(nodeNames, node.Name)
    }
    // --all-namespaces -> listing and looping on namespaces
    namespaces, err := clientset.CoreV1().Namespaces().List(metav1.ListOptions{})

    if err != nil {
        return err
    }
    for _, namespace := range namespaces.Items {
        for _, name := range nodeNames {
            // pods need a namespace to be listed.
            pods, err := clientset.CoreV1().Pods(namespace.Name).List(metav1.ListOptions{FieldSelector: "spec.nodeName=" + name})
            if err != nil {
                println("%v", err)
            }
            for _, pod := range pods.Items {
                fmt.Println(pod.Namespace, pod.Name)
            }
        }
    }
    return nil
}

我已经开始发现,我需要问的很多问题对于CLI来说变得太复杂了,CLI是一个很好的工具,但是学习使用Go客户端可以帮助你得到你想要的第一个答案,而且还可以深入挖掘这些答案提出的问题。

相关问题