2023 腾讯云容器和函数计算技术实践精选集
15
进行评分。
同时动态调度器提供了一个默认值调度策略并支持用户自定义策略。默认策略依赖于以下指
标：
cpu_usage_avg_5m
cpu_usage_max_avg_1h
cpu_usage_max_avg_1d
mem_usage_avg_5m
mem_usage_max_avg_1h
mem_usage_max_avg_1d
在调度的Filter阶段，如果该节点的实际使用率大于上述任一指标的阈值，则该节点将被过滤。
而在 Score 阶段，最终得分是这些指标值的加权和。
在生产集群中，可能会频繁出现调度热点，因为创建 Pod 后节点的负载不能立即增加。因
此定义了一个额外的指标，名为 Hot Value，表示节点最近几次的调度频率。并且节点的最
终优先级是最终得分减去 Hot Value。
关键代码实现
●
Node-annotation
定期从 Prometheus 拉取数据，并以注释的形式在节点上用时间戳标记它们
// /pkg/controller/annotator/node.go
func (n *nodeController) syncNode(key string) (bool, error) {
startTime := time.Now()
defer func() {
klog.Infof("Finished syncing node event %q (%v)", key, time.Since(startTime))
}()
// 获取 nodeName, metricName
nodeName, metricName, err := splitMetaKeyWithMetricName(key)
// 通过 nodeName 获取 node 的具体信息
node, err := n.nodeLister.Get(nodeName)
// 通过 nodeIP 或者 nodeName 获取并更新 node 的监控指标
err = annotateNodeLoad(n.promClient, n.kubeClient, node, metricName)
// 获取 node hotVaule，并更新
err = annotateNodeHotValue(n.kubeClient, n.bindingRecords, node, n.policy)
return true, nil
}
func annotateNodeLoad(promClient prom.PromClient, kubeClient clientset.Interface, node *v1.Node,
key string) error {
// 通过 nodeIp 查询
value, err := promClient.QueryByNodeIP(key, getNodeInternalIP(node))
if err == nil && len(value) > 0 {
return patchNodeAnnotation(kubeClient, node, key, value)
}
// 通过 nodeName 查询
value, err = promClient.QueryByNodeName(key, getNodeName(node))
if err == nil && len(value) > 0 {
return patchNodeAnnotation(kubeClient, node, key, value)
}
return fmt.Errorf("failed to get data %s{%s=%s}: %v", key, node.Name, value, err)
}
剩余189页未读，继续阅读
