|
@@ -146,9 +146,8 @@ const (
|
|
|
queryRAMRequestsStr = `avg(
|
|
queryRAMRequestsStr = `avg(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
- avg(
|
|
|
|
|
- sum_over_time(kube_pod_container_resource_requests{resource="memory", unit="byte", container!="",container!="POD", node!="", %s}[%s] %s)
|
|
|
|
|
- ) by (namespace,container,pod,node,%s) , "container_name","$1","container","(.+)"
|
|
|
|
|
|
|
+ sum_over_time(kube_pod_container_resource_requests{resource="memory", unit="byte", container!="",container!="POD", node!="", %s}[%s] %s)
|
|
|
|
|
+ , "container_name","$1","container","(.+)"
|
|
|
), "pod_name","$1","pod","(.+)"
|
|
), "pod_name","$1","pod","(.+)"
|
|
|
)
|
|
)
|
|
|
) by (namespace,container_name,pod_name,node,%s)`
|
|
) by (namespace,container_name,pod_name,node,%s)`
|
|
@@ -164,9 +163,8 @@ const (
|
|
|
queryCPURequestsStr = `avg(
|
|
queryCPURequestsStr = `avg(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
- avg(
|
|
|
|
|
- sum_over_time(kube_pod_container_resource_requests{resource="cpu", unit="core", container!="",container!="POD", node!="", %s}[%s] %s)
|
|
|
|
|
- ) by (namespace,container,pod,node,%s) , "container_name","$1","container","(.+)"
|
|
|
|
|
|
|
+ sum_over_time(kube_pod_container_resource_requests{resource="cpu", unit="core", container!="",container!="POD", node!="", %s}[%s] %s)
|
|
|
|
|
+ , "container_name","$1","container","(.+)"
|
|
|
), "pod_name","$1","pod","(.+)"
|
|
), "pod_name","$1","pod","(.+)"
|
|
|
)
|
|
)
|
|
|
) by (namespace,container_name,pod_name,node,%s)`
|
|
) by (namespace,container_name,pod_name,node,%s)`
|
|
@@ -184,14 +182,11 @@ const (
|
|
|
queryGPURequestsStr = `avg(
|
|
queryGPURequestsStr = `avg(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
label_replace(
|
|
label_replace(
|
|
|
- avg(
|
|
|
|
|
- sum_over_time(kube_pod_container_resource_requests{resource="nvidia_com_gpu", container!="",container!="POD", node!="", %s}[%s] %s)
|
|
|
|
|
- * %f
|
|
|
|
|
- ) by (namespace,container,pod,node,%s) , "container_name","$1","container","(.+)"
|
|
|
|
|
|
|
+ sum_over_time(kube_pod_container_resource_requests{resource="nvidia_com_gpu", container!="",container!="POD", node!="", %s}[%s] %s),
|
|
|
|
|
+ "container_name","$1","container","(.+)"
|
|
|
), "pod_name","$1","pod","(.+)"
|
|
), "pod_name","$1","pod","(.+)"
|
|
|
)
|
|
)
|
|
|
- ) by (namespace,container_name,pod_name,node,%s)
|
|
|
|
|
- * on (pod_name, namespace, %s) group_left(container) label_replace(avg(avg_over_time(kube_pod_status_phase{phase="Running", %s}[%s] %s)) by (pod,namespace,%s), "pod_name","$1","pod","(.+)")`
|
|
|
|
|
|
|
+ ) by (namespace,container_name,pod_name,node,%s)`
|
|
|
queryPVRequestsStr = `avg(avg(kube_persistentvolumeclaim_info{volumename != "", %s}) by (persistentvolumeclaim, storageclass, namespace, volumename, %s, kubernetes_node)
|
|
queryPVRequestsStr = `avg(avg(kube_persistentvolumeclaim_info{volumename != "", %s}) by (persistentvolumeclaim, storageclass, namespace, volumename, %s, kubernetes_node)
|
|
|
*
|
|
*
|
|
|
on (persistentvolumeclaim, namespace, %s, kubernetes_node) group_right(storageclass, volumename)
|
|
on (persistentvolumeclaim, namespace, %s, kubernetes_node) group_right(storageclass, volumename)
|
|
@@ -1740,11 +1735,11 @@ func (cm *CostModel) costDataRange(cli prometheusClient.Client, cp costAnalyzerC
|
|
|
|
|
|
|
|
queryRAMAlloc := fmt.Sprintf(queryRAMAllocationByteHours, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
queryRAMAlloc := fmt.Sprintf(queryRAMAllocationByteHours, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
|
queryCPUAlloc := fmt.Sprintf(queryCPUAllocationVCPUHours, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
queryCPUAlloc := fmt.Sprintf(queryCPUAllocationVCPUHours, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
|
- queryRAMRequests := fmt.Sprintf(queryRAMRequestsStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel(), env.GetPromClusterLabel())
|
|
|
|
|
|
|
+ queryRAMRequests := fmt.Sprintf(queryRAMRequestsStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
queryRAMUsage := fmt.Sprintf(queryRAMUsageStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
queryRAMUsage := fmt.Sprintf(queryRAMUsageStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
- queryCPURequests := fmt.Sprintf(queryCPURequestsStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel(), env.GetPromClusterLabel())
|
|
|
|
|
|
|
+ queryCPURequests := fmt.Sprintf(queryCPURequestsStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
queryCPUUsage := fmt.Sprintf(queryCPUUsageStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
queryCPUUsage := fmt.Sprintf(queryCPUUsageStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
- queryGPURequests := fmt.Sprintf(queryGPURequestsStr, env.GetPromClusterFilter(), resStr, "", resolution.Hours(), env.GetPromClusterLabel(), env.GetPromClusterLabel(), env.GetPromClusterLabel(), env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
|
|
|
|
+ queryGPURequests := fmt.Sprintf(queryGPURequestsStr, env.GetPromClusterFilter(), resStr, "", env.GetPromClusterLabel())
|
|
|
queryPVRequests := fmt.Sprintf(queryPVRequestsStr, env.GetPromClusterFilter(), env.GetPromClusterLabel(), env.GetPromClusterLabel(), env.GetPromClusterFilter(), env.GetPromClusterLabel(), env.GetPromClusterLabel())
|
|
queryPVRequests := fmt.Sprintf(queryPVRequestsStr, env.GetPromClusterFilter(), env.GetPromClusterLabel(), env.GetPromClusterLabel(), env.GetPromClusterFilter(), env.GetPromClusterLabel(), env.GetPromClusterLabel())
|
|
|
queryPVCAllocation := fmt.Sprintf(queryPVCAllocationFmt, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
queryPVCAllocation := fmt.Sprintf(queryPVCAllocationFmt, env.GetPromClusterFilter(), resStr, env.GetPromClusterLabel(), scrapeIntervalSeconds)
|
|
|
queryPVHourlyCost := fmt.Sprintf(queryPVHourlyCostFmt, env.GetPromClusterFilter(), resStr)
|
|
queryPVHourlyCost := fmt.Sprintf(queryPVHourlyCostFmt, env.GetPromClusterFilter(), resStr)
|