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

读取Kubernets文档，看起来可以根据标签选择一定范围的pod。我想选择一个节点上的所有pod，但不想在相应的节点上标记每个pod。

我是否从文档中遗漏了一些东西，或者只是不可能按节点选择?

如果我这样做:

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


#=>


NAME   READY     STATUS             RESTARTS   AGE       NODE

这些头可以用作选择器吗?如果是，如何用kubectl来做?如何用API做到这一点?

165291 次浏览
小开

按nodeName排序的示例:

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
小开

你想要的在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中

小开

你也可以用下面的命令查询一个节点上的所有pod

kubectl get pods -o wide --all-namespaces | grep <YOUR-NODE>
小开 
kubectl describe node $NODE

将显示在$NODE上运行的所有未终止的pod。

小开
最佳答案

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

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

我用Go客户端也经历了同样的过程，它揭示了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客户端可以帮助你得到你想要的第一个答案，而且还可以更深入地挖掘这些答案提出的问题。


提交答案