Kubernetes 客户端提供了丰富的 API 来管理和操作 Kubernetes 集群中的资源。以下是一些常见的操作示例，涵盖了指标获取、资源管理、自定义资源定义（CRD）以及类型化和无类型资源 API 的使用。
获取 Metrics
Kubernetes 客户端支持从启用了指标的 API 服务器获取指标。你可以通过 client.top() 访问指标。
获取所有节点的 NodeMetrics：
NodeMetricsList nodeMetricList = client.top().nodes().metrics();
复制代码
获取特定节点的 NodeMetrics：
NodeMetrics nodeMetric = client.top().nodes().withName("minikube").metric();
复制代码
获取所有命名空间中所有 Pod 的 PodMetrics：
PodMetricsList podMetricsList = client.top().pods().metrics();
复制代码
获取某个特定命名空间中所有 Pod 的 PodMetrics：
PodMetricsList podMetricsList = client.top().pods().inNamespace("default").metrics();
复制代码
获取特定 Pod 的 PodMetrics：
PodMetrics podMetrics = client.top().pods().metrics("default", "nginx-pod");
复制代码
Resource API
Resource 是 Kubernetes 中表示集群中可用计算资源（如 CPU、内存）的抽象概念，用于定义 Pod 的资源请求（requests）和限制（limits）。
Kubernetes 客户端提供了一个通用 API 来处理不同类型的 Kubernetes 资源。大多数 Kubernetes 资源都扩展了 HasMetadata 类。
从 Kubernetes API 服务器获取 Kubernetes 资源：
Pod pod = client.resource(pod1).inNamespace("default").get();
复制代码
将 Kubernetes 资源应用到 Kubernetes 集群（服务器端应用）：
Pod pod1 = new PodBuilder() .withNewMetadata().withName("resource-pod-" + RandomStringUtils.randomAlphanumeric(6).toLowerCase(Locale.ROOT)).endMetadata() .withNewSpec() .addNewContainer().withName("nginx").withImage("nginx").endContainer() .endSpec() .build();
client.resource(pod1).inNamespace("default").serverSideApply();
复制代码
应用 Kubernetes 资源并等待资源准备就绪：
pod1 = client.resource(pod1).serverSideApply();Pod p = client.pods().resource(pod1).waitUntilReady(10, TimeUnit.SECONDS);
复制代码
删除 Kubernetes 资源：
client.resource(pod1).inNamespace("default").delete();
复制代码
Resource List
Kubernetes 客户端还提供了一个通用 API 来处理 Kubernetes 列表。
将 Kubernetes 资源列表应用到 Kubernetes 集群：
Service service = new ServiceBuilder() .withNewMetadata().withName("my-service").endMetadata() .withNewSpec() .addToSelector("app", "Myapp") .addNewPort().withProtocol("TCP").withPort(80).withTargetPort(new IntOrString(9376)).endPort() .endSpec() .build();
ConfigMap configMap = new ConfigMapBuilder() .withNewMetadata().withName("my-configmap").endMetadata() .addToData(Collections.singletonMap("app", "Myapp")) .build();
KubernetesList list = new KubernetesListBuilder().withItems(deployment, service, configMap).build();
// 应用client.resourceList(list).inNamespace("default").serverSideApply();
复制代码
删除资源列表：
client.resourceList(new PodListBuilder().withItems(pod1, pod2, pod3).build()).inNamespace("default").delete();
复制代码
自定义资源定义（CRD）
自定义资源定义（CRD） 是 Kubernetes 中允许用户扩展 API 的机制，用于定义和管理自定义资源（Custom Resource），满足特定应用或业务需求。
CustomResourceDefinition 是 Kubernetes API 中 CustomResource 对象的模板。
从 yaml 文件加载 CustomResourceDefinition：
CustomResourceDefinition customResourceDefinition = client.apiextensions().v1().customResourceDefinitions().load(new FileInputStream("/sparkapplication-crd.yml")).item();
复制代码
从 Kubernetes API 服务器获取 CustomResourceDefinition：
CustomResourceDefinition crd = client.apiextensions().v1().customResourceDefinitions().withName("sparkclusters.radanalytics.io").get();
复制代码
创建 CustomResourceDefinition：
CustomResourceDefinition customResourceDefinition = new CustomResourceDefinitionBuilder() .withApiVersion("apiextensions.k8s.io/v1") .withNewMetadata().withName("sparkclusters.radanalytics.io") .endMetadata() .withNewSpec() .withNewNames() .withKind("SparkCluster") .withPlural("sparkclusters") .endNames() .withGroup("radanalytics.io") .withVersion("v1") .withScope("Namespaced") .withNewValidation() .withNewOpenAPIV3SchemaLike(readSchema()) .endOpenAPIV3Schema() .endValidation() .endSpec() .build();
CustomResourceDefinition crd = client.apiextensions().v1().customResourceDefinitions().resource(customResourceDefinition).create();
复制代码
应用 CustomResourceDefinition：
CustomResourceDefinition crd = client.apiextensions().v1().customResourceDefinitions().resource(customResourceDefinition).serverSideApply();
复制代码
列出 CustomResourceDefinition：
CustomResourceDefinitionList crdList = client.apiextensions().v1().customResourceDefinitions().list();
复制代码
删除 CustomResourceDefinition：
client.apiextensions().v1().customResourceDefinitions().withName("sparkclusters.radanalytics.io").delete();
复制代码
资源类型化 API
任何资源（无论是自定义资源还是内置资源）都可以通过 client.resources(Class) 方法访问。
获取自定义资源的客户端实例：
MixedOperation<CronTab, KubernetesResourceList<CronTab>, Resource<CronTab>> cronTabClient = client.resources(CronTab.class);
复制代码
从 Kubernetes API 服务器获取自定义资源：
CronTab ct = cronTabClient.inNamespace("default").withName("my-second-cron-object").get();
复制代码
创建 CustomResource：
cronTabClient.inNamespace("default").create(cronTab1);
复制代码
列出 CustomResource：
CronTabList cronTabList = cronTabClient.inNamespace("default").list();
复制代码
删除 CustomResource：
cronTabClient.inNamespace("default").withName("my-third-cron-object").delete();
复制代码
替换 CustomResource 的状态：
cronTabClient.inNamespace("default").resource(updatedCronTab).updateStatus();
复制代码
修补 CustomResource 的状态：
cronTabClient.inNamespace("default").resource(updatedCronTab).patchStatus();
复制代码
编辑 CustomResource 的状态：
cronTabClient.inNamespace("default").resource(cronTab1).editStatus(cronTab -> updatedCronTab);
复制代码
监听 CustomResource：
cronTabClient.inNamespace("default").watch(new Watcher<>() { @Override public void eventReceived(Action action, CronTab resource) { // 根据操作类型执行某些操作 }
@Override public void onClose(WatcherException cause) { // 处理关闭事件 }});
复制代码
无类型资源
如果你不需要或不想使用强类型的客户端，Kubernetes 客户端还提供了一个无类型/原始 API 来处理资源。
创建 ResourceDefinitionContext：
ResourceDefinitionContext resourceDefinitionContext = new ResourceDefinitionContext.Builder() .withGroup("jungle.example.com") .withVersion("v1") .withPlural("animals") .withNamespaced(true) .build();
复制代码
从 YAML 文件加载资源：
GenericKubernetesResource customResource = client.genericKubernetesResources(context).load(new FileInputStream("cr.yaml")).item();
复制代码
从 Kubernetes API 服务器获取资源：
GenericKubernetesResource customResourceObject = client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).withName("otter").get();
复制代码
创建资源：
GenericKubernetesResource object = client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).load(new FileInputStream("test-rawcustomresource.yml")).create();
复制代码
列出 CustomResource：
GenericKubernetesResourceList list = client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).list();
复制代码
更新 CustomResource：
GenericKubernetesResource walrus = client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).withName("walrus").get();Map<String, Object> spec = (Map<String, Object>) walrus.getAdditionalProperties().get("spec");spec.put("image", "my-updated-awesome-walrus-image");walrus.getAdditionalProperties().put("spec", spec);client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).resource(walrus).update();
复制代码
删除 CustomResource：
client.genericKubernetesResources(resourceDefinitionContext).inNamespace(currentNamespace).withName("otter").delete();
复制代码
监听 CustomResource：
final CountDownLatch closeLatch = new CountDownLatch(1);client.genericKubernetesResources(crdContext).inNamespace(namespace).watch(new Watcher<>() { @Override public void eventReceived(Action action, GenericKubernetesResource resource) { logger.info("{}: {}", action, resource); }
@Override public void onClose(WatcherException e) { logger.debug("Watcher onClose"); closeLatch.countDown(); if (e != null) { logger.error(e.getMessage(), e); } }});closeLatch.await(10, TimeUnit.MINUTES);
复制代码
Spark Operator
以下示例展示了如何通过 Spark Operator 的示例以两种不同的方式为自定义资源定义相同的上下文。
类型化资源 API：
@Group("sparkoperator.k8s.io")@Plural("sparkapps")@Version("v1beta2")@Kind("SparkApplication")public class SparkOperatorResource extends GenericKubernetesResource implements Namespaced { ... }
复制代码
使用类型化资源 API 的 SparkOperatorResource：
kubernetesClient.resources(SparkOperatorResource.class).inNamespace("myNamespace")...
复制代码
无类型资源 API：
public static ResourceDefinitionContext getResourceDefinitionContext() { return new ResourceDefinitionContext.Builder() .withGroup("sparkoperator.k8s.io") .withPlural("sparkapps") .withVersion("v1beta2") .withKind("SparkApplication") .withNamespaced(true) .build();}
复制代码
使用无类型资源 API：
kubernetesClient.genericKubernetesResources(getResourceDefinitionContext()).inNamespace("myNamespace")...
复制代码
通过这些 API，你可以灵活地管理和操作 Kubernetes 集群中的各种资源，无论是内置资源还是自定义资源。
评论