Fabric8 Kubernetes 教程——Metrics、Resource
Fabric8 Kubernetes 教程——Metrics、Resource
FunTester
发布于 2025-04-04 04:53:07
发布于 2025-04-04 04:53:07
代码可运行
运行总次数：2
代码可运行
关联问题
换一批
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 集群中的各种资源，无论是内置资源还是自定义资源。
本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。
原始发表：2025-04-01，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
暂无评论
推荐阅读
推荐阅读
相关推荐
Fabric8 Kubernetes 教程——客户端基础
更多 >腾讯云开发者
