java - 使用 Java Kubernetes 客户端 API 部署 Pod 并为其分配节点

Question

我正在使用 kubeadm 创建 kubernetes 集群。如何将 Pod 部署到特定节点上。下面的代码用于在简单的 minikube 集群中部署 pod。谢谢

        ApiClient client = Config.defaultClient();
        Configuration.setDefaultApiClient(client);

        CoreV1Api api = new CoreV1Api();
        V1ObjectMeta meta = new V1ObjectMeta();

        meta.name("ms2-pod");
        Map<String, String> labels = new HashMap<>();
        labels.put("app", "ms2-pod");
        meta.labels(labels);
        V1ContainerPort port = new V1ContainerPort();
        port.containerPort(9090);
        V1Container container = new V1Container();
        container.name("ms2-container");
        container.image("ms2");
        container.imagePullPolicy("IfNotPresent");
        container.ports(Arrays.asList(port));

        V1PodSpec spec = new V1PodSpec();
        spec.containers(Arrays.asList(container));
        V1Pod podBody = new V1Pod();
        podBody.apiVersion("v1");
        podBody.kind("Pod");
        podBody.metadata(meta);
        podBody.spec(spec);

        V1Pod pod = api.createNamespacedPod("default", podBody, null, null, null);

我们如何使用 Java 中的 K8S 客户端 Api 充分利用 kubeadm 集群内的 kubectl 功能？

Answer 1

您可以使用node selectors or node affinity or anti-affinity取决于你想做什么。

• Node Name ，这是将 pod 调度到特定节点的最简单方法，由于其局限性，不推荐使用。
• 节点选择器将允许您使用 label selectors 选择具有特定标签的节点。
• 节点关联性的工作方式几乎与节点选择器相同，但允许您指定选择器中定义的规则是必需的还是首选的。即使不满足约束，也允许 pod 被调度到任何其他节点。

下面是使用节点选择器的示例(假设您将名为“nodeLabelKey”且值为“nodeLabelValue”的标签添加到节点):

    ApiClient client = Config.defaultClient();
    Configuration.setDefaultApiClient(client);

    CoreV1Api api = new CoreV1Api();
    V1ObjectMeta meta = new V1ObjectMeta();

    meta.name("ms2-pod");
    Map<String, String> labels = new HashMap<>();
    labels.put("app", "ms2-pod");
    meta.labels(labels);
    V1ContainerPort port = new V1ContainerPort();
    port.containerPort(9090);
    V1Container container = new V1Container();
    container.name("ms2-container");
    container.image("ms2");
    container.imagePullPolicy("IfNotPresent");
    container.ports(Arrays.asList(port));

    V1PodSpec spec = new V1PodSpec();
    spec.containers(Arrays.asList(container));
    V1Pod podBody = new V1Pod();
    podBody.apiVersion("v1");
    podBody.kind("Pod");
    podBody.metadata(meta);
    podBody.spec(spec);

    Map<String, String> nodeSelectorMap = new HashMap<>();
    nodeSelectorMap.put("nodeLabelKey", "nodeLabelValue");
    spec.nodeSelector(nodeSelectorMap);

    V1Pod pod = api.createNamespacedPod("default", podBody, null, null, null);