使用 client-go 直接针对 Kubernetes API 进行“kubectl apply”，并在单个 YAML 文件中使用多种类型

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

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

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

我想使用 client-go 在 go 代码中模仿此清单的 kubectl apply。

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

我已成功将 createed 单一 api 类型添加到我的集群中，但是对于包含不同类型列表的清单，我该如何执行此操作？是否有资源 kind: list* 支持这些不同类型？

我当前的解决方法是使用 csplit 分割 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/serializer

它在 client-go 中公开：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 来获取输出？

看起来 runconvert 正在弃用

我还查看了标记为 [client-go] 的其他问题，但大多数使用旧示例或使用定义了单个 kind 的 yaml 文件，并且 api 自此发生了更改。

编辑：因为我需要对多个集群执行此操作，并且以编程方式创建集群（aws eks api + cloudformation/eksctl），所以我希望最大限度地减少跨多个集群上下文、多个 aws 账户创建 serviceaccounts 的开销。理想情况下，创建客户端集涉及的唯一身份验证步骤是使用 aws-iam-authenticator 使用集群数据（名称、区域、ca 证书等）获取令牌。 aws-iam-authenticator 已经有一段时间没有发布了，但是 master 的内容允许使用第三方角色跨账户角色和外部 id 进行传递。 imo，这比使用 serviceaccount （和 irsa）更干净，因为应用程序（创建附加组件并将其应用到这些集群的后端 api）需要与其他 aws 服务进行交互。

编辑：我最近发现了 https://github.com/ericchiang/k8s。从高层来看，它肯定比 client-go 使用起来更简单，但不支持这种行为。

解决方案

听起来您已经弄清楚如何将 yaml 文件反序列化到 kubernetes runtime.objects 中，但问题是动态部署 runtime.object 而无需为每种类型编写特殊代码。

kubectl 通过直接与 REST API 交互来实现此目的。具体请拨打 resource.Helper。

在我的代码中，我有类似的内容：

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

func createObject(kubeClientset kubernetes.Interface, restConfig rest.Config, obj runtime.Object) (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 nil, 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 nil, err
    }

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

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

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

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)
}

我能够在我的一个项目中实现此功能。我必须使用 kubectl 的 apply 命令中的大部分源代码才能使其正常工作。

https://github.com/billiford/go-clouddriver/blob/master/pkg/kubernetes/client.go#L63

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~