Kubernetes API - получает поды на определенных узлах

Как упоминалось в принятом ответе, PR теперь объединен, и вы можете получить поды по узлам следующим образом:

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

Пример сортировки модулей по имени узла:

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

Пример получения подов на узлах с помощью фильтра меток:

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:

$ 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

Вы также можете запросить все модули в узле с помощью следующей команды

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

kubectl describe node <node> покажет все незавершенные модули, работающие на этом узле.

То, что вы хотите, поддерживается на стороне сервера 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

Я проделал тот же процесс с 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
}

Я начал обнаруживать, что многие вопросы, которые мне нужно задать, становятся слишком сложными для интерфейса командной строки, который является отличной рабочей лошадкой, но обучение использованию Go Client может помочь вам получить первый ответ, который вы ищете, но также углубитесь в вопросы, которые поднимают эти ответы.