如何反序列化 Kubernetes YAML 文件答案

【问题标题】：How to deserialize Kubernetes YAML file如何反序列化 Kubernetes YAML 文件
【发布时间】：2017-11-02 13:03:53
【问题描述】：

如何将 Kubernetes YAML 文件反序列化为 Go 结构？我查看了kubectl 代码，但不知何故，每个 YAML 文件都有一个错误：

no kind "Deployment" is registered for version "apps/v1beta1"

这是一个 MWE：

package main

import (
    "fmt"

    "k8s.io/client-go/pkg/api"
)

var service = `
apiVersion: apps/v1beta1
kind: Deployment
metadata:
  name: my-nginx
spec:
  replicas: 2
  template:
    metadata:
      labels:
        run: my-nginx
    spec:
      containers:
      - name: my-nginx
        image: nginx
        ports:
        - containerPort: 80
`

func main() {
    decode := api.Codecs.UniversalDecoder().Decode
    //decode := api.Codecs.UniversalDeserializer().Decode

    obj, _, err := decode([]byte(service), nil, nil)
    if err != nil {
        panic(err)
    }

    fmt.Printf("%#v\n", obj)
}

我正在使用客户端版本2.0.0。 glide.yaml 看起来像这样：

package: test/stackoverflow
import:
- package: k8s.io/client-go
  version: ^2.0.0

这些是对kubectl的引用：

不幸的是，docs 让我很困惑，所以我不知道如何解决这个问题。

编辑：

其他资源类型也存在此问题：

no kind "Service" is registered for version "v1"

【问题讨论】：

想试试 Go dep 吗？ hackernoon.com/…
这与依赖管理无关。
是的，我知道（因此我的回答如下），但我试图鼓励人们转向更面向未来的替代方案；）

标签： go kubernetes kubernetes-go-client

【解决方案1】：

您需要导入_ "k8s.io/client-go/pkg/apis/extensions/install" 否则架构为空，另请参阅docs。

完整的工作示例是：

$ go get -u github.com/golang/dep/cmd/dep
$ dep init
$ go run main.go

以下main.go：

package main

import (
    "fmt"

    "k8s.io/client-go/pkg/api"
    _ "k8s.io/client-go/pkg/api/install"
    _ "k8s.io/client-go/pkg/apis/extensions/install"
)

var deployment = `
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: my-nginx
spec:
replicas: 2
template:
  metadata:
    labels:
      run: my-nginx
  spec:
    containers:
    - name: my-nginx
      image: nginx
      ports:
      - containerPort: 80
`

func main() {
    // decode := api.Codecs.UniversalDecoder().Decode
    decode := api.Codecs.UniversalDeserializer().Decode

    obj, _, err := decode([]byte(deployment), nil, nil)
    if err != nil {
        fmt.Printf("%#v", err)
    }

    fmt.Printf("%#v\n", obj)
}

请注意，我还为您导入了 _ "k8s.io/client-go/pkg/api/install"，以便您可以使用 v1 中的对象，例如 pod 或服务。

编辑：感谢我的同事 Stefan Schimanski，他提出了最初的解决方案。

【讨论】：

哇。这很神奇 ;-) 另一方面，如果一个人想要一个可扩展的系统，这是可以理解的。我想这些文档是可以改进的。谢谢！
确实非常接近魔法，在 Stefan 来救援之前，我自己也在闲逛了一会儿。文档需要大量改进，好吧，同意！
嗨@MichaelHausenblas，我正在尝试使这项工作（解析k8s yaml以使用Go结构）但不能使其与dep（或vndr）一起使用。复制你完全相同的例子，并运行“dep init”得到：没有k8s.io/apimachinery的版本遇到限制：master：无法更新签出版本：：命令失败：[git checkout 1168e538ea3ccf444854d1fdd5681d2d876680a7]：退出状态128（下一条评论)
@MichaelHausenblas 看起来上面的示例已被弃用，因为 import _ "k8s.io/client-go/pkg/api/install" 不起作用。还单击文档显示Not Found。你能更新一下吗？
接受的答案已过时 - 没有更多的 k8s.io/client-go/api/install 包。请参阅 github 讨论并修正版本：github.com/kubernetes/client-go/issues/…

【解决方案2】：

我一直在使用 api machine'sk8s.io/apimachinery/pkg/util/yaml 来解码 kubernete 的部署和服务清单。

import (
   "fmt"
   "bytes"
   appsv1 "k8s.io/api/apps/v1"
    k8Yaml "k8s.io/apimachinery/pkg/util/yaml"
)
...

d := &appsv1.Deployment{}
dec := k8Yaml.NewYAMLOrJSONDecoder(bytes.NewReader([]byte(deploymentManifest)), 1000)

if err := dec.Decode(&d); err != nil {
        return nil, err
}

fmt.Printf("%+v", d)

【讨论】：

如何获取特定 pod 的 deployment.yaml/service.yaml
如果你有 pod 对象，你可以检查 ownerReferences 来获取拥有该 pod 的副本集。在replicaset对象中，查看ownerReferences的值来获取部署。
service比较棘手，可以使用pod上的label在services中查找匹配，但是效率不高。

【解决方案3】：

import (
    "fmt"
    "gopkg.in/yaml.v2"
    "log"
    //corev1 "k8s.io/api/core/v1"
    "k8s.io/apimachinery/pkg/runtime/serializer/json"
    "k8s.io/client-go/kubernetes/scheme"
    v1alpha1 "github.com/argoproj/argo-cd/pkg/apis/application/v1alpha1"
)

....

func ParseYaml2(yaml []byte) (v1alpha1.Application, error) {
    // Create a YAML serializer.  JSON is a subset of YAML, so is supported too.
    s := json.NewYAMLSerializer(json.DefaultMetaFactory, scheme.Scheme,
        scheme.Scheme)

    // Decode the YAML to an object.
    var app v1alpha1.Application
    _, _, err := s.Decode(yaml, nil, &app)
    if err != nil {
        panic(err)
    }
    //fmt.Printf("%#v\n", app)
    return app, err
}
---
go.mod
// https://github.com/argoproj/argo-cd/issues/4055
replace github.com/argoproj/argo-cd => github.com/argoproj/argo-cd v1.5.5

var yaml2 = []byte(`
apiVersion: argoproj.io/v1alpha1
kind: Application
metadata:
...

var app v1alpha1.Application
app,err := ParseYaml2(yaml2)
// Types from https://github.com/argoproj/argo-cd/blob/master/pkg/apis/application/v1alpha1/types.go
    fmt.Printf("--- t:\n%s\n\n", app.Spec.Source.Path)
    fmt.Printf("--- t:\n%s\n\n", app.Spec.Source.Helm.ValueFiles)
----

【讨论】：