在单个 YAML 文件中使用多种类型直接针对 Kubernetes API 使用 client-go 到 `kubectl apply`

学习Golang要努力，但是不要急！今天的这篇文章《在单个 YAML 文件中使用多种类型直接针对 Kubernetes API 使用 client-go 到 `kubectl apply`》将会介绍到golang等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

问题内容

我正在使用https://github.com/kubernetes/client- go并且一切正常。

我有官方 Kubernetes 仪表板的清单 (YAML)：https ://raw.githubusercontent.com/kubernetes/dashboard/v2.0.0-beta4/aio/deploy/recommended.yaml

我想kubectl apply在 Go 代码中模仿这个清单，使用 client-go。

我知道我需要将 YAML 字节编组为包中定义的正确 API 类型：https ://github.com/kubernetes/api

我已经成功地Create将单个 API 类型编辑到我的集群中， 但是如何为包含不同类型列表的清单执行此操作 ？是否有kind: List*支持这些不同类型的资源？

csplit我当前的解决方法是使用with --- 作为分隔符来拆分 YAML 文件

csplit /path/to/recommended.yaml /---/ '{*}' --prefix='dashboard.' --suffix-format='%03d.yaml'

接下来，我循环创建新的 (14) 部分，读取它们的字节，打开 UniversalDeserializer 解码器返回的对象类型，并使用我的 k8s 客户端集调用正确的 API 方法。

我想以编程方式执行此操作，以便将仪表板的任何新版本更新到我的集群中。我还需要为 Metrics Server 和许多其他资源执行此操作。另一种（可能更简单）的方法是将安装了 kubectl 的代码发送到容器映像并直接调用kubectl apply -f -; 但这意味着我还需要将 kube 配置写入磁盘，或者内联传递它，以便 kubectl 可以使用它。

我发现这个问题很有帮助：https ://github.com/kubernetes/client-go/issues/193 解码器住在这里：https ://github.com/kubernetes/apimachinery/tree/master/pkg/runtime/串行器

它在 client-go 中公开：[https ://github.com/kubernetes/client- go/blob/master/kubernetes/scheme/register.go#L69](https://github.com/kubernetes/client- go/blob/master/kubernetes/scheme/register.go#L69)

我还查看了 kubectl 使用的 RunConvert 方法：https ://github.com/kubernetes/kubernetes/blob/master/pkg/kubectl/cmd/convert/convert.go#L139并假设我可以提供我自己的[genericclioptions.IOStreams](https://github.com/kubernetes/cli- runtime/blob/master/pkg/genericclioptions/io_options.go#L27)来获取输出吗？

看起来 RunConvert 处于弃用路径

我还查看了标记为 [client-go] 的其他问题，但大多数使用旧示例或使用带有单个kind定义的 YAML 文件，此后 API 发生了变化。

编辑：因为我需要为多个集群执行此操作，并且正在以编程方式创建集群（AWS EKS API + CloudFormation/ eksctl），所以我想尽量减少ServiceAccount跨多个 AWS 账户创建跨多个集群上下文的开销。理想情况下，创建我的客户端集所涉及的唯一身份验证步骤是使用[aws-iam- authenticator](https://github.com/kubernetes-sigs/aws-iam- authenticator)使用集群数据（名称、区域、CA 证书等）获取令牌。有一段时间没有发布aws-iam- authenticator，但是内容master允许使用第三方角色跨账户角色和外部ID传递。IMO，这比使用ServiceAccount（和[IRSA](https://docs.aws.amazon.com/eks/latest/userguide/iam- roles-for-service-accounts.html)) 因为应用程序（创建附加组件并将其应用到这些集群的后端 API）需要与之交互的其他 AWS 服务。

编辑：我最近发现https://github.com/ericchiang/k8s。在高层次上，它绝对比 client-go 更简单，但不支持这种行为。

正确答案

听起来您已经知道如何将 YAML 文件反序列化为 Kubernetes runtime.Object，但问题是动态部署 aruntime.Object而无需为每种 Kind 编写特殊代码。

kubectl[通过直接与REST API](https://godoc.org/k8s.io/client- go/rest)交互来实现这一点。具体来说，通过[resource.Helper](https://godoc.org/k8s.io/cli- runtime/pkg/resource#Helper)。

在我的代码中，我有类似的东西：

import (
    meta "k8s.io/apimachinery/pkg/api/meta"
    "k8s.io/cli-runtime/pkg/resource"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    "k8s.io/client-go/restmapper"
    "k8s.io/apimachinery/pkg/runtime"
)

func createObject(kubeClientset kubernetes.Interface, restConfig rest.Config, obj runtime.Object) error {
    // Create a REST mapper that tracks information about the available resources in the cluster.
    groupResources, err := restmapper.GetAPIGroupResources(kubeClientset.Discovery())
    if err != nil {
        return err
    }
    rm := restmapper.NewDiscoveryRESTMapper(groupResources)

    // Get some metadata needed to make the REST request.
    gvk := obj.GetObjectKind().GroupVersionKind()
    gk := schema.GroupKind{Group: gvk.Group, Kind: gvk.Kind}
    mapping, err := rm.RESTMapping(gk, gvk.Version)
    if err != nil {
        return err
    }

    name, err := meta.NewAccessor().Name(obj)
    if err != nil {
        return err
    }

    // Create a client specifically for creating the object.
    restClient, err := newRestClient(restConfig, mapping.GroupVersionKind.GroupVersion())
    if err != nil {
        return err
    }

    // Use the REST helper to create the object in the "default" namespace.
    restHelper := resource.NewHelper(restClient, mapping)
    return restHelper.Create("default", false, obj, &metav1.CreateOptions{})
}

func newRestClient(restConfig rest.Config, gv schema.GroupVersion) (rest.Interface, error) {
    restConfig.ContentConfig = resource.UnstructuredPlusDefaultContentConfig()
    restConfig.GroupVersion = &gv
    if len(gv.Group) == 0 {
        restConfig.APIPath = "/api"
    } else {
        restConfig.APIPath = "/apis"
    }

    return rest.RESTClientFor(&restConfig)
}

好了，本文到此结束，带大家了解了《在单个 YAML 文件中使用多种类型直接针对 Kubernetes API 使用 client-go 到 `kubectl apply`》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！