如何使用 java io.fabric8 kubernetes-client 库获取节点 CPU% 和 MEMORY% 值

Question

kubectl 顶部节点
\nNAME \xe2\x80\x83\xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xe2\ x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 CPU(核心) \xe2\x80\x83 CPU%\xe2\x80\x83 内存(字节)\xe2\x80\x83 内存%
\xe2\x80\x83
\ngsdjsgfhdsgfz-12345665-jisj000000 934m \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 24% \xe2\x80\x83 \xe2\x80\x83 10439Mi \x e2\ x80 \ x83 \ xe2 \ x80 \ x83 \
x83 \ x80 \ x80 \ x83 82％\ ngsdjsgfhdsgfz-112345665-jisj000001 717m e2 \ x80 \ x83 \xe2\x80\x83 9132Mi \xe2\x80\x83 \xe2\x80\x83 \xe2\x80\x83 \xc2\xa0 72%
\ngsdjsgfhdsgfz-12345665-jisj000002 1099m \xe2\x80\x83 \xe2\x80 \x83 \xc2\xa0 \xc2\xa0 28% \xe2\x80\x83 \xe2\x80\x83 7614Mi \xe2\x80\x83 \xe2\x80\x83\xe2\x80\x83\xc2\xa0 60%

\n

如何使用 java io.fabric8 kubernetes-client 库获取 CPU% 和 MEMORY% 值。

\n

try (KubernetesClient k8s = new DefaultKubernetesClient()) {\n\nNodeMetricsList nodeMetricsList = k8s.top().nodes().metrics();\nfor (NodeMetrics nodeMetrics : nodeMetricsList.getItems()) {\n      logger.info("{} {} {}", nodeMetrics.getMetadata().getName(),\n        nodeMetrics.getUsage().get("cpu"),\n        nodeMetrics.getUsage().get("memory"));\n}\n

\n

}

\n

获取输出为：-
\n节点名称
\ncpu:-1094942089n
\n内存:-7830672Ki

\n

如何取百分比值？

\n

Answer 1

我最近必须实现同样的功能，不幸的是，我没有找到一种仅通过使用top()API 来获取百分比的方法，我必须执行两个调用，一个调用是nodes()为了检索总容量，另一个调用是为了top()检索已用容量容量。然后就只是计算百分比的问题了。

工作代码片段：

public static void main(String[] args) {
    KubernetesClient kubernetesClient = new DefaultKubernetesClient();
    Map<String, Node> nodeMap = kubernetesClient.nodes().list().getItems()
        .stream()
        .collect(Collectors.toMap(node -> node.getMetadata().getName(), Function.identity()));
    List<NodeUsage> usageList = kubernetesClient.top().nodes().metrics().getItems()
        .stream()
        .map(metric -> new NodeUsage(nodeMap.get(metric.getMetadata().getName()), metric.getUsage()))
        .collect(Collectors.toList());
    System.out.println(usageList);
  }

  private static class NodeUsage {
    private final Node node;
    private final BigDecimal cpuPercentage;
    private final BigDecimal memoryPercentage;

    private NodeUsage(Node node, Map<String, Quantity> used) {
      this.node = node;
      cpuPercentage = calculateUsage(used.get("cpu"), node.getStatus().getAllocatable().get("cpu"));
      memoryPercentage = calculateUsage(used.get("memory"), node.getStatus().getAllocatable().get("memory"));
    }

    private static BigDecimal calculateUsage(Quantity used, Quantity total) {
      return Quantity.getAmountInBytes(used)
          .divide(Quantity.getAmountInBytes(total), 2, RoundingMode.FLOOR)
          .multiply(BigDecimal.valueOf(100));
    }

    public Node getNode() {
      return node;
    }

    public BigDecimal getCpuPercentage() {
      return cpuPercentage;
    }

    public BigDecimal getMemoryPercentage() {
      return memoryPercentage;
    }
  }