14

我正在使用 AWS 的 EKS，它是 Kubernetes v1.10，我正在使用 client-go v7.0.0。

我要做的是解析一个文件中包含多个 Kubernetes 资源定义的 .yml 文件，并将这些资源提交给 Kubernetes API。我可以使用此代码成功解析文件scheme.Codecs.UniversalDeserializer().Decode，并返回一个runtime.Object.

我知道所有的 Kubernetes 资源都符合runtime.Object接口，但是我找不到将通用接口提交给 API 的方法。我见过的大多数方法都使用具体类型的方法，如 Deployment、Pod 等。

我已经看到了一些围绕这样的通用 RESTClient 的代码clientset.RESTClient().Put().Body(obj).Do()，但这不起作用，我无法弄清楚。

我知道我的客户端配置正确，因为我可以成功列出所有 Pod。

4

2 回答 2

11

如果您有“通用” runtime.Object，则可以为此使用 client-go 中的动态客户端。动态客户端处理unstructured.Unstructured对象，所有runtime.Objects 都可以转换为它。这是一个例子：

// create the dynamic client from kubeconfig
dynamicClient, err := dynamic.NewForConfig(kubeconfig)
if err != nil {
    return err
}

// convert the runtime.Object to unstructured.Unstructured
unstructuredObj, err := runtime.DefaultUnstructuredConverter.ToUnstructured(obj)
if err != nil {
    return err
}

// create the object using the dynamic client
nodeResource := schema.GroupVersionResource{Version: "v1", Resource: "Node"}
createdUnstructuredObj, err := dynamicClient.Resource(nodeResource).Namespace(ns).Create(unstructuredObj)
if err != nil {
    return err
}

// convert unstructured.Unstructured to a Node
var node *corev1.Node
if err = runtime.DefaultUnstructuredConverter.FromUnstructured(createdUnstructuredObj, node); err != nil {
    return err
}
于 2018-11-18T09:31:40.360 回答
5

您需要动态客户端是正确的，但要保持与 runtime.Object 通用的工作，您需要使用 DiscoveryRESTMapper ，它需要使用类型化客户端来发现可用的 api 版本：

dynClient, err := dynamic.NewForConfig(config)
...
clientset, err := kubernetes.NewForConfig(config)
...
gvk := obj.GroupVersionKind()
gk := schema.GroupKind{Group: gvk.Group, Kind: gvk.Kind}
groupResources, err := restmapper.GetAPIGroupResources(clientset.Discovery())
...
rm := restmapper.NewDiscoveryRESTMapper(groupResources)
mapping, err := rm.RESTMapping(gk, gvk.Version)
...
dynClient.Resource(mapping.Resource).Namespace("default").Create(obj, metav1.CreateOptions{})
于 2019-03-21T18:43:14.007 回答