锐客网

  1. 首页 > 睿知 > it技术 > >

k8s 通过node节点获取资源信息

IT知识节点资源

【k8s 通过node节点获取资源信息】智者不为愚者谋，勇者不为怯者死。这篇文章主要讲述k8s 通过node节点获取资源信息相关的知识，希望能为你提供帮助。

  • 获取node节点GPU/CPU/Mem 的capacity和request 数
func GetNodeResource(allPods []v1.Pod, node *v1.Node) (resource map[string]model.ResourceStatus, err error)
var (
allocatedGPU int64
allocatedCPU int64
allocatedMem int64
capacityGPUint64
)
resource = map[string]model.ResourceStatus
val, ok := node.Status.Capacity[common.NvidiaGPUResource]
if !ok
capacityGPU = 0
else
capacityGPU = val.Value()

for _, pod := range getPodsFromNode(allPods, node)
allocatedGPU += gpuInPod(& pod)
allocatedCPU += cpuInPod(& pod)
allocatedMem += memInPod(& pod)

resource[common.ResourceGPU] = model.ResourceStatus
Request:allocatedGPU,
Capacity: capacityGPU,

resource[common.ResourceCPU] = model.ResourceStatus
Request:allocatedCPU,
Capacity: node.Status.Capacity.Cpu().Value(),

resource[common.ResourceMemory] = model.ResourceStatus
Request:allocatedMem,
Capacity: node.Status.Capacity.Memory().Value(),

return resource, nil

// 获取节点上的pod
func getPodsFromNode(allPods []v1.Pod, node *v1.Node) (pods []v1.Pod)
for _, pod := range allPods
if pod.Spec.NodeName == node.Name
pods = append(pods, pod)


return pods

// 获取所有的running的pod
func AllActivePods(clientSet *kubernetes.Clientset) ([]v1.Pod, error)
allPods, err := clientSet.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions
FieldSelector: "status.phase=Running",
)
if err != nil
log.Infof("get pods err, %s", err)
return nil, err

log.Infof("Running pod count %d", len(allPods.Items))
return allPods.Items, nil

// 获取pod上的gpu request
func gpuInPod(pod *v1.Pod) (gpuCount int64)
containers := pod.Spec.Containers
for _, container := range containers
val, ok := container.Resources.Limits[common.NvidiaGPUResource]
if !ok
continue

gpuCount += val.Value()

return gpuCount

// 获取pod上的cpu request
func cpuInPod(pod *v1.Pod) (cpuCount int64)
containers := pod.Spec.Containers
for _, container := range containers
val, ok := container.Resources.Requests[common.ResourceCPU]
if !ok
continue

cpuCount += val.Value()

return cpuCount

// 获取pod上的mem request
func memInPod(pod *v1.Pod) (memCount int64)
containers := pod.Spec.Containers
for _, container := range containers
val, ok := container.Resources.Requests[

    推荐阅读


    上一篇：Everything 的高级用法

    下一篇：家用打印机推荐