kubernetes - kubectl apply -f 相当于fabric8 java api

Question

我试图使用 io.fabric8 api 使用 pod-spec.yaml 在 kubernetes 中创建一些资源。

Config config = new ConfigBuilder()
                  .withNamespace("ag")
                  .withMasterUrl(K8_URL)
                  .build();
try (final KubernetesClient client = new DefaultKubernetesClient(config)) {

            LOGGER.info("Master: " + client.getMasterUrl());

            LOGGER.info("Loading File : " + args[0]);
            Pod pod = client.pods().load(new FileInputStream(args[0])).get();
            LOGGER.info("Pod created with name : " + pod.toString());

} catch (Exception e) {

            LOGGER.error(e.getMessage(), e);

}

如果资源类型为 POD，则上述代码有效。同样对于其他资源类型，它工作正常。
但是如果 yaml 在同一个文件中有多个资源类型，如 POD 和服务，如何使用 fabric8 Api ？

我试图使用 client.load(new FileInputStream(args[0])).createOrReplace();但它因以下异常而崩溃:

java.lang.NullPointerException
    at java.net.URI$Parser.parse(URI.java:3042)
    at java.net.URI.<init>(URI.java:588)
    at io.fabric8.kubernetes.client.utils.URLUtils.join(URLUtils.java:48)
    at io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:208)
    at io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:177)
    at io.fabric8.kubernetes.client.handlers.PodHandler.reload(PodHandler.java:53)
    at io.fabric8.kubernetes.client.handlers.PodHandler.reload(PodHandler.java:32)
    at io.fabric8.kubernetes.client.dsl.internal.NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.createOrReplace(NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.java:202)
    at io.fabric8.kubernetes.client.dsl.internal.NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.createOrReplace(NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.java:62)
    at com.nokia.k8s.InterpreterLanuch.main(InterpreterLanuch.java:66)

使用的 Yaml 文件

apiVersion: v1
kind: Pod
metadata:
  generateName: zep-ag-pod
  annotations:
    kubernetes.io/psp: restricted
    spark-app-name: Zeppelin-spark-shared-process
  namespace: ag
  labels:
    app: zeppelin
    int-app-selector: shell-123

spec:
  containers:
    - name: ag-csf-zep
      image: bcmt-registry:5000/zep-spark2.2:9
      imagePullPolicy: IfNotPresent
      command: ["/bin/bash"]
      args: ["-c","echo Hi && sleep 60 && echo Done"]
      securityContext:
        allowPrivilegeEscalation: false
        capabilities:
          drop:
          - ALL
        runAsNonRoot: true
  securityContext:
    fsGroup: 2000
    runAsUser: 1510
  serviceAccount: csfzeppelin
  serviceAccountName: csfzeppelin
---
apiVersion: v1
kind: Service
metadata:
  name: zeppelin-service
  namespace: ag
  labels:
    app: zeppelin
spec:
  type: NodePort
  ports:
  - name: zeppelin-service
    port: 30099
    protocol: TCP
    targetPort: 8080
  selector:
    app: zeppelin

Answer 1

加载包含多个文档的文件时，您无需指定资源类型。您只需要执行以下操作:

  // Load Yaml into Kubernetes resources
  List<HasMetadata> result = client.load(new FileInputStream(args[0])).get();
  // Apply Kubernetes Resources
  client.resourceList(result).inNamespace(namespace).createOrReplace()