- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
我想解析 kubernetes list 文件 (json/yaml) 并能够将它们转换为 k8s 结构(以便稍后操作它们)
我知道有 NewYAMLOrJSONDecoder().Decode() 函数(https://github.com/kubernetes/apimachinery/blob/master/pkg/util/yaml/decoder.go)可以读取 json/yaml 文件,但下一步是:如何将它们转换为 k8s 结构/类型?
即例如,如果我读取带有命名空间对象的 yaml 文件,如何将其转换为核心/v1/命名空间接口(interface)
问候,
最佳答案
谢谢 svenwltr,我不知道我们可以这样做。
与此同时,我设法找到了一种不同的方法,而不是更好的方法:
package main
import (
"flag"
"fmt"
"os"
"io"
"path/filepath"
"log"
"encoding/json"
//"time"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/discovery"
"k8s.io/client-go/dynamic"
"k8s.io/apimachinery/pkg/util/yaml"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/api/meta"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
)
func main() {
var kubeconfig *string
if home := homeDir(); home != "" {
kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
} else {
kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
}
flag.Parse()
// use the current context in kubeconfig
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err.Error())
}
// create the clientset
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
}
f,err := os.Open("namespace.yaml")
if err!=nil {
log.Fatal(err)
}
d := yaml.NewYAMLOrJSONDecoder(f,4096)
dd := clientset.Discovery()
apigroups,err := discovery.GetAPIGroupResources(dd)
if err != nil {
log.Fatal(err)
}
restmapper := discovery.NewRESTMapper(apigroups,meta.InterfacesForUnstructured)
for {
// https://github.com/kubernetes/apimachinery/blob/master/pkg/runtime/types.go
ext := runtime.RawExtension{}
if err := d.Decode(&ext); err!=nil {
if err == io.EOF {
break
}
log.Fatal(err)
}
fmt.Println("raw: ",string(ext.Raw))
versions := &runtime.VersionedObjects{}
//_, gvk, err := objectdecoder.Decode(ext.Raw,nil,versions)
obj, gvk, err := unstructured.UnstructuredJSONScheme.Decode(ext.Raw,nil,versions)
fmt.Println("obj: ",obj)
// https://github.com/kubernetes/apimachinery/blob/master/pkg/api/meta/interfaces.go
mapping, err := restmapper.RESTMapping(gvk.GroupKind(), gvk.Version)
if err != nil {
log.Fatal(err)
}
restconfig := config
restconfig.GroupVersion = &schema.GroupVersion {
Group: mapping.GroupVersionKind.Group,
Version: mapping.GroupVersionKind.Version,
}
dclient,err := dynamic.NewClient(restconfig)
if err != nil {
log.Fatal(err)
}
// https://github.com/kubernetes/client-go/blob/master/discovery/discovery_client.go
apiresourcelist, err := dd.ServerResources()
if err != nil {
log.Fatal(err)
}
var myapiresource metav1.APIResource
for _,apiresourcegroup := range(apiresourcelist) {
if apiresourcegroup.GroupVersion == mapping.GroupVersionKind.Version {
for _,apiresource := range(apiresourcegroup.APIResources) {
//fmt.Println(apiresource)
if apiresource.Name == mapping.Resource && apiresource.Kind == mapping.GroupVersionKind.Kind {
myapiresource = apiresource
}
}
}
}
fmt.Println(myapiresource)
// https://github.com/kubernetes/client-go/blob/master/dynamic/client.go
var unstruct unstructured.Unstructured
unstruct.Object = make(map[string]interface{})
var blob interface{}
if err := json.Unmarshal(ext.Raw,&blob); err != nil {
log.Fatal(err)
}
unstruct.Object = blob.(map[string]interface{})
fmt.Println("unstruct:",unstruct)
ns := "default"
if md,ok := unstruct.Object["metadata"]; ok {
metadata := md.(map[string]interface{})
if internalns,ok := metadata["namespace"]; ok {
ns = internalns.(string)
}
}
res := dclient.Resource(&myapiresource,ns)
fmt.Println(res)
us,err := res.Create(&unstruct)
if err != nil {
log.Fatal(err)
}
fmt.Println("unstruct response:",us)
}
}
func homeDir() string {
if h := os.Getenv("HOME"); h != "" {
return h
}
return os.Getenv("USERPROFILE") // windows
}
关于api - 客户端去: parse kubernetes json files to k8s structures,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47116811/
很难说出这里问的是什么。这个问题是含糊的、模糊的、不完整的、过于宽泛的或修辞性的,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开它,visit the help center 。 已关
我们可以说 O(K + (N-K)logK)相当于O(K + N logK)对于 1 < = K <= N ? 最佳答案 简短的回答是它们不等价,这取决于k 的值。如果k等于N,那么第一个复杂度是O(
我有以下解决方案,但我从其他评论者那里听说它是 O(N * K * K),而不是 O(N * K)其中 N 是 K 列表的(最大)长度,K 是列表的数量。例如,给定列表 [1, 2, 3] 和 [4,
我试图理解这些语法结构之间的语义差异。 if ((i% k) == (l % k) == 0) 和 if ((i % k) == 0 && (l % k) == 0) 最佳答案 您的特定表达式((i
我有时会使用一维数组: A = np.array([1, 2, 3, 4]) 或 2D 阵列(使用 scipy.io.wavfile 读取单声道或立体声信号): A = np.array([[1, 2
在文档聚类过程中,作为数据预处理步骤,我首先应用奇异向量分解得到U、S和Vt 然后通过选择适当数量的特征值,我截断了 Vt,这让我从阅读的内容中得到了很好的文档-文档相关性 here .现在我正在对矩
我问的是关于 Top K 算法的问题。我认为 O(n + k log n) 应该更快,因为……例如,如果您尝试插入 k = 300 和 n = 100000000,我们可以看到 O(n + k log
这个问题与另一个问题R:sample()密切相关。 。我想在 R 中找到一种方法来列出 k 个数字的所有排列,总和为 k,其中每个数字都是从 0:k 中选择的。如果k=7,我可以从0,1,...,7中
我目前正在评估基于隐式反馈的推荐系统。我对排名任务的评估指标有点困惑。具体来说,我希望通过精确度和召回率来进行评估。 Precision@k has the advantage of not requ
我在 Python 中工作,需要找到一种算法来生成所有可能的 n 维 k,k,...,k 数组,每个数组都沿轴有一行 1。因此,该函数接受两个数字 - n 和 k,并且应该返回一个数组列表,其中包含沿
我们有 N 对。每对包含两个数字。我们必须找到最大数 K,这样如果我们从给定的 N 对中取 J (1 2,如果我们选择三对 (1,2),我们只有两个不同的数字,即 1 和 2。 从一个开始检查每个可能
鉴于以下问题,我不能完全确定我当前的解决方案: 问题: 给定一个包含 n 元素的最大堆,它存储在数组 A 中,是否可以打印所有最大的 K 元素在 O(K*log(K)) 中? 我的回答: 是的,是的,
我明白了: val vector: RDD[(String, Array[String])] = [("a", {v1,v2,..}),("b", {u1,u2,..})] 想转换成: RDD[(St
我有 X 个正数,索引为 x_i。每个 x_i 需要进入 K 组之一(其中 K 是预先确定的)。令 S_j 为 K_j 中所有 x_i 的总和。我需要分配所有 x_i 以使所有 S_j 的方差最小化。
关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。 这个问题是由于错别字或无法再重现的问题引起的。虽然类似的问题可能是on-topi
我正在研究寻找原始数的算法,看到下面的语句,我不明白为什么。 while (k*k <= n) 优于 while (k <= Math.sqrt(n)) 是因为函数调用吗?该调用函数使用更多资源。 更
我想找到一种尽可能快的方法来将两个小 bool 矩阵相乘,其中小意味着 8x8、9x9 ... 16x16。这个例程会被大量使用,所以需要非常高效,所以请不要建议直截了当的解决方案应该足够快。 对于
有没有一种惯用的方法来获取 Set和 Function ,并获得 Map实时取景? (即 Map 由 Set 和 Function 组合支持,例如,如果将元素添加到 Set ,则相应的条目也存在于 M
这个问题在这里已经有了答案: Can a local variable's memory be accessed outside its scope? (20 个答案) returning addr
给定一个矩阵:- k = [1 2 3 ; 4 5 6 ; 7 8 NaN]; 如果我想用 0 替换一个数字,比如 2,我可以使用这个:k(k==2) =
我是一名优秀的程序员,十分优秀!