Heim >Backend-Entwicklung >Golang >So erhalten Sie „freundliche' Antworten vom Kubernetes APIServer mithilfe der ReST-Schnittstelle
Der PHP-Editor Apple stellt Ihnen vor, wie Sie die ReST-Schnittstelle verwenden, um eine „freundliche“ Antwort vom Kubernetes APIServer zu erhalten. Kubernetes ist eine beliebte Container-Orchestrierungsplattform, die APIs zur Verwaltung und Überwachung verschiedener Ressourcen im Cluster bereitstellt. Durch die Verwendung der ReST-Schnittstelle können wir problemlos mit dem Kubernetes APIServer interagieren und die benötigten Informationen erhalten. In diesem Artikel erfahren Sie im Detail, wie Sie mithilfe der ReST-Schnittstelle authentifizieren, Anfragen senden und Antworten verarbeiten sowie mit möglichen Fehlerbedingungen umgehen. Egal, ob Sie Kubernetes-Neuling oder ein erfahrener Kubernetes-Benutzer sind, dieser Artikel bietet Ihnen nützliche Anleitungen und praktische Ratschläge.
Ich verwende die Golang-Client-Go-Bibliothek, um mit dem Kubernetes-API-Server auf Ruhe-Get- und Post-Ebene zu kommunizieren. Die empfangene Antwort ist weder eine wohlgeformte JSON-Struktur noch eine „Art“ API-Objekt.
Das Programmfragment ist:
kubeconfig := filepath.join( os.getenv("home"), ".kube", "config", ) config, err := clientcmd.buildconfigfromflags("", kubeconfig) if err != nil { log.fatal(err) } config.negotiatedserializer = scheme.codecs.withoutconversion() groupversion, _ := schema.parsegroupversion("api/v1") config.groupversion = &groupversion config.contenttype = "application/json" config.acceptcontenttypes = "application/json" examplerestclient, err := rest.restclientfor(config) if err != nil { panic(err) } var statuscode int var contenttype string response, err := examplerestclient. get(). resource("nodes"). do(context.background()). statuscode(&statuscode). contenttype(&contenttype). get() if err != nil { panic(err) } fmt.printf("content-type is %s\n", contenttype) fmt.printf("status code is %d\n", statuscode) fmt.printf("received response %v\n", response)
Antwort beginnt mit:
status code is 200 received response &nodelist{listmeta:{ 17299 <nil>},items:[]node{node{objectmeta:{dev-cluster-control-plane 7fe038c9-8be6-41a9-9f3f-5900abb0e34b 16922 0 2023-02-19 16:32:44 +0530 ist <nil> <nil> map[beta.kubernetes.io/arch:amd64 beta.kubernetes.io/os:linux kubernetes.io/arch:amd64 kubernetes.io/hostname:dev-cluster-control-plane kubernetes.io/os:linux node-role.kubernetes.io/control-plane: node.kubernetes.io/exclude-from-external-load-balancers:] map[kubeadm.alpha.kubernetes.io/cri-socket:unix:///run/containerd/containerd.sock node.alpha.kubernetes.io/ttl:0 volumes.kubernetes.io/controller-managed-attach-detach:true] [] [] ...
Ich erwarte eine Ausgabe, die der des folgenden Befehls ähnelt:
$ kubectl get --raw /api/v1/nodes {"kind":"NodeList","apiVersion":"v1","metadata":{"resourceVersion":"17481"},"items":[{"metadata":{"name":"dev-cluster-control-plane","uid":"7fe038c9-8be6-41a9-9f3f-5900abb0e34b","resourceVersion":"17351","creationTimestamp":"2023-02-19T11:02:44Z","labels":{"beta.kubernetes.io/arch":"amd64","beta.kubernetes.io/os":"linux","kubernetes.io/arch":"amd64","kubernetes.io/hostname":"dev-cluster-control-plane","kubernetes.io/os":"linux","node-role.kubernetes.io/control-plane":"","node.kubernetes.io/exclude-from-external-load-balancers":""},"annotations":{"kubeadm.alpha.kubernetes.io/cri-socket":"unix:///run/containerd/containerd.sock","node.alpha.kubernetes.io/ttl":"0" ...
Die erhaltene Antwort ist keine wohlgeformte JSON-Struktur
Ich glaube, Sie sind verwirrt darüber, wie das client-go
-Modul funktioniert.
Die Antwort der restlichen API ist definitiv eine wohlgeformte JSON-Antwort, aber diese wird in eine Go-Datenstruktur (wie diese ) entmarshallt.
Wenn Sie auf die zurückgegebenen Knoten zugreifen möchten, können Sie mithilfe der Standard-Go-Syntax mit den Ergebnissen interagieren:
response, err := examplerestclient. get(). resource("nodes"). do(context.background()). statuscode(&statuscode). contenttype(&contenttype). get() if err != nil { panic(err) } nodes := response.(*v1.nodelist) for _, node := range nodes.items { fmt.printf("name: %s\n", node.objectmeta.getname()) fmt.printf("addresses:\n") for _, addr := range node.status.addresses { fmt.printf(" %s: %s\n", addr.type, addr.address) } }
Ich erwarte eine Ausgabe, die der des folgenden Befehls ähnelt:
Warum?client-go
Bindungen geben Daten zurück, die für Ihren Go-Code nützlich sind. Wenn Sie eine JSON-Ausgabe generieren möchten, müssen Sie die Ressource explizit im JSON-Format bereitstellen:
response, err := exampleRestClient. Get(). Resource("nodes"). Do(context.Background()). StatusCode(&statusCode). ContentType(&contentType). Get() if err != nil { panic(err) } out, err := json.Marshal(response) fmt.Print(string(out))
Das obige ist der detaillierte Inhalt vonSo erhalten Sie „freundliche' Antworten vom Kubernetes APIServer mithilfe der ReST-Schnittstelle. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!