php小编苹果将向大家介绍如何使用ReST接口从Kubernetes APIServer获取"友善"响应。Kubernetes是一个流行的容器编排平台,它提供了API来管理和监控集群中的各种资源。通过使用ReST接口,我们可以方便地与Kubernetes APIServer进行交互,并获取到我们需要的信息。在本文中,我们将详细探讨如何使用ReST接口进行认证、发送请求并处理响应,以及如何处理可能出现的错误情况。无论您是新手还是有经验的Kubernetes用户,本文都将为您提供有用的指导和实践建议。
我正在使用 golang client-go 库在 rest get、post 级别与 kubernetes api 服务器进行通信。收到的响应不是格式良好的 json 结构,也不是“种类”的 api 对象。
程序片段为:
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)
响应开头为:
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] [] [] ...
我期望输出类似于以下命令返回的内容:
$ 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" ...
收到的响应不是格式良好的 json 结构
我认为您对 client-go
模块的运行方式感到困惑。
来自 rest api 的响应绝对是格式良好的 json 响应,但这会被解组到 go 数据结构中(例如 这个)。
如果您想访问返回的节点,您可以使用标准 go 语法与结果进行交互:
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) } }
我期望输出类似于以下命令返回的内容:
为什么?client-go
绑定返回对您的 go 代码有用的数据。如果要生成 json 输出,则需要将资源显式封送为 json 格式:
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))
以上是如何使用 ReST 接口从 Kubernetes APIServer 获取'友善”响应的详细内容。更多信息请关注PHP中文网其他相关文章!