在传统的中间件运维过程中,存在以下几个突出问题:
Kubernetes(K8s)和 Operator 提供了一套通用的运维管理机制,将中间件运维操作抽象成 Kubernetes CR(Custom Resource)对象,由 Operator 负责具体的运维执行。这种模式具备以下优势:
标准化:运维操作可以以 CR 为中心进行统一管理。
自动化:减少了人工干预,降低了人为失误的风险。
可视化:可以通过 UI 平台降低运维复杂度。
基于上述背景,我们决定建设一个统一的中间件运维平台,目标包括:
在展开详细的建设内容前,我们先看看整体的架构设计。本架构图展示了白屏化运维平台的核心组成和各层之间的交互关系,帮助我们更直观地理解平台的整体运作逻辑和功能分布。
运维平台层是整个白屏化运维平台的中枢大脑,承上启下,连接用户层与 Kubernetes 集群层,同时对接外部系统,确保运维操作的标准化、自动化和可审计。它的架构图如下:
运维平台的具体作用包括:
多云管理服务
中间件运维服务
K8s 通用资源管理服务
YAML 管理服务
操作审计服务
运维平台层不仅是各类运维操作的执行中枢,更是数据流通的核心枢纽,负责将用户的运维请求转化为 Kubernetes 资源变更操作,同时记录和审计所有操作,确保系统的安全性和可追溯性。
接下来,我们将深入剖析这些核心服务,看看它们是如何在实际场景中解决痛点、提升效率的。
“Kubeconfig 切换地狱,谁用谁知道。”
小卡作为一名资深 SRE,每天都要在多个 Kubernetes 集群之间穿梭,管理不同环境下的资源。这些集群来自不同的云厂商,运行在不同的 Kubernetes 版本上,甚至还有不同的认证和网络策略。
多 kubeconfig 文件管理混乱
操作风险高
跨云兼容性问题
访问性能瓶颈
根据运维同学的痛点,我们计划构建一个多云 Kubernetes 集群管理平台,实现跨云环境资源的统一托管、可视化管理与快速访问,避免 kubeconfig 切换带来的混乱和风险。效果图如下:
目标和行动拆解:
截至目前,平台已跨云托管了30+套Kubernetes集群。
“Kafka 扩容——一个让人捏把汗的运维操作”
凌晨三点,运维小卡的手机突然爆炸式震动起来,屏幕上跳出无数条报警消息:“Kafka 集群负载过高,CPU 使用率接近 100%!”
小卡揉了揉惺忪的睡眼,坐在电脑前打开黑屏终端,迅速敲下一连串熟练的命令:
kubectl --kubeconfig=k8s-xxx-prd get kafka
他屏住呼吸,盯着屏幕上的滚动字符,一行一行地检查 Kafka 集群状态,判断哪些节点资源吃紧,哪些副本需要扩容。然而,每次操作都让他倍感焦虑——“这可是生产环境啊,万一一行命令敲错,就要上新闻头条了!”
四步流程,看似简单,但每一步都需要小卡屏息凝神,稍有差错,就可能导致数据丢失,甚至集群崩溃。
“这种凌晨抢救场面,为什么不能更简单一点?”
小卡心里忍不住嘀咕。
在中间件运维场景中,Kafka 集群扩容是一项典型的复杂运维任务。这不仅仅是一个简单的「增加节点」操作,还涉及到集群状态监控、资源调度、数据迁移等多个环节。
传统方式下,SRE 需要通过黑屏脚本完成扩容任务,整个过程不仅繁琐,还充满了不确定性。
以下是一个 Kafka 集群扩容的典型黑屏脚本示例:
#!/bin/bash
# 设置 kubeconfig
export KUBECONFIG=/path/to/kubeconfig
# 1. 检查 Kafka 集群状态
echo "Step 1: 查询 Kafka 集群状态"
kubectl get kafka -n kafka-namespace
# 2. 扩容 Kafka 集群副本数
echo "Step 2: 扩容 Kafka 集群"
kubectl patch kafka my-cluster -n kafka-namespace --type='merge' -p '{"spec":{"kafka":{"replicas":5}}}'
# 3. 轮询 Kafka Pod 状态
echo "Step 3: 检查所有 Kafka Pod 是否 Running"
while true; do
READY_PODS=$(kubectl get pods -n kafka-namespace -l app.kubernetes.io/name=kafka -o jsonpath='{.items[*].status.phase}' | grep -o "Running" | wc -l)
TOTAL_PODS=5
echo "Running Pods: $READY_PODS / $TOTAL_PODS"
if [ "$READY_PODS" -eq "$TOTAL_PODS" ]; then
echo "所有 Kafka Pod 已经就绪"
break
fi
sleep 5
done
# 4. 触发数据迁移
echo "Step 4: 开始数据迁移"
curl -X POST "http://cruise-control.kafka-namespace.svc.cluster.local:9090/kafkacruisecontrol/rebalance" -d "dryrun=false"
# 5. 轮询数据迁移状态
echo "Step 5: 等待数据迁移完成"
while true; do
STATUS=$(curl -s "http://cruise-control.kafka-namespace.svc.cluster.local:9090/kafkacruisecontrol/user_tasks" | grep "COMPLETED")
if [ -n "$STATUS" ]; then
echo "数据迁移完成"
break
fi
sleep 10
done
echo "Kafka 集群扩容完成!"
可以看到,传统脚本有以下几个痛点:
多步骤手动介入
缺乏可视化
风险高
不可审计
目标:将 Kafka 扩容的整个过程标准化、可视化、自动化,降低操作风险,提升执行效率。
从此,凌晨三点的 Kafka 扩容,变成了这样的场景:
“10 分钟,Kafka 扩容完成,小卡又可以安心地回床上睡觉了。”,如下图:
目前,Kafka和ES在运维中都面临相似的痛点。为解决这些问题,大部分通用的中间件运维操作已被统一收敛至平台。
截至目前,平台已累计托管300+个中间件集群(Kafka: 120+,ES: 180+),完成100+个中间件的运维操作(Kafka: 60+,ES: 40+),累计执行430+次白屏化运维操作(Kafka: 210+次,ES: 220+次),覆盖扩缩容、升降配、数据迁移、重启、重建等常见运维场景,极大提升了运维效率与操作稳定性。
“凌晨三点,ES集群扩容需求紧急上线。”
运维小哥小吴接到告警电话,ES集群节点资源已接近饱和,业务性能明显下降。扩容节点,是当务之急。
然而,扩容并不是简单地加几台机器那么轻松。Node打标是扩容的关键前置步骤,如果节点没有正确打标,Pod将无法被调度到对应的资源池,扩容将直接失败。
在过去,Node 资源调度和打标是一项高风险、高强度的任务。需要依赖脚本在黑屏终端中逐台节点检查 CPU、内存、磁盘类型、可用区 等指标,然后筛选出符合条件的节点进行打标和调度。
如果某个细节疏忽——比如忘记检查污点、磁盘挂载数量超标,轻则导致扩容失败,重则影响整个业务链路。
在传统的 Node 筛选脚本中,我们依赖 kubectl 命令逐个检查节点的各类资源指标,并进行节点筛选。以下是小吴编写的一个典型的黑屏脚本示例:
public class ESNodeSelectorTest {
public static void main(String[] args) {
//cpu核心数
int needCpu = 9;
//内存容量G
int needMemory = 33;
//磁盘类型
DiskType needDiskType = DiskType.efficiency;
//可用区
Zone zone = Zone.cn_shanghai_m;
//标签
String label = null;
//集群名称
String clusterName = null;
//开始自动筛选
selectNode(label,zone,needCpu,needMemory,needDiskType,clusterName);
}
public static void selectNode(String label,Zone zone,int needCpu,int needMemory,DiskType diskType,String clusterName){
String getNodes = "kubectl get node -l ";
String segment;
if(label!=null){
getNodes += label;
}else {
if (zone != null) {
segment = "topology.kubernetes.io/zone=" + zone.name().replaceAll("_", "-");
getNodes += segment;
}
}
String nodes = executeCommand("/bin/bash", "-c", getNodes);
String[] nodeList = nodes.split("\n");
String describeNode;
int lineCount = 0;
for (int i = 1; i < nodeList.length; i++) {
String node = nodeList[i].split(" ",2)[0];
if(lineCount>4){
lineCount = 0;
System.out.println();
}
lineCount++;
System.out.print(node);
if(isMaster(node)){
continue;
}
describeNode = "kubectl describe node " + node +" | grep 'Taints\\|cpu \\|memory ";
//...太多了...省略...
}
}
}
public static String executeCommand(String... command){
try {
Process process = Runtime.getRuntime().exec(command);
//...
}catch (Exception e){
throw new RuntimeException("kubectl apply exception:",e);
}
}
}
可以看到,传统方式有以下几个痛点:
操作复杂
高风险
响应慢
目标:
将 Node 资源管理的整个流程标准化、自动化和可视化。
**设计思路:
1.指标可视化**
2.多维度筛选
3.批量打标与调度
4.资源状态实时更新
在大促扩容场景中,平台已累计完成了 280+ 台 Node 的打标与调度。原本1小时+的 Node 筛选和打标操作,现在只需要 3 分钟 。
“集群删了,PV 留下了,云盘成了‘孤儿’。”
一次运维例会中,小宋提到这样一个现象:当中间件集群被释放后,原先挂载的 PV 和云厂商的云盘并不会自动删除。更让人头疼的是,云厂商云盘的标签只有两个关键字段,这里以某云为例:
当集群被销毁,这些标签几乎无法追溯到云盘的真正使用方。出于风险考虑,这些云盘被闲置着,无人敢于释放,久而久之,闲置云盘成堆,云成本居高不下。如下图:
云盘归属无法追溯
手动释放繁琐
流程缺乏闭环
目标:实现 PV 云盘资源的可视化、自动化管理,打通从 Kubernetes 到云厂商的全链路操作流程。如下图所示:
目标和行动拆解:
截止目前,平台已累计释放了 675+ 块闲置云盘,每月节省云成本约 15+万元。操作时间从15 分钟+缩短到 1 分钟。且所有操作均可审计与回溯,保障了运维安全性。
“高峰期 CPU 100%,服务卡成 PPT?”
一次业务高峰来临,ES 集群的 CPU 使用率迅速飙升到 100%,多个关键服务开始响应迟缓,甚至部分 Pod 被强制驱逐。运维同学小宋看着监控大屏上的红色告警,不禁捏了一把汗。
在传统运维方式下,CPU 资源一旦达到极限,唯一的解决方案就是扩容,但扩容并非瞬时可完成的操作,往往需要排查资源、调度 Pod、重启服务,甚至等待新节点的资源分配。而这些步骤,在高并发、高压力场景下,每一秒的延迟都是用户体验的巨大损失。
资源调度滞后
临时应急难
解决方案
目标:在高压场景下,通过 CPU Burst 管理功能,允许关键 Pod 在短时间内突破 CPU Limit 限制,保障服务稳定性和业务连续性。如下所示:
截止目前, CPU Burst 已在 10+ 套 Kubernetes 集群 和 30+ 套 ES 集群 中启用。在高并发场景下,有效解决了 CPU受限和CPU使用率瓶颈问题,提升了服务稳定性。
“一行 YAML,毁灭一个集群。”
在 Kubernetes 的运维场景中,YAML 配置文件是所有资源操作的核心。无论是 Pod 调度、Service 暴露,还是 ConfigMap 更新,所有的操作都离不开 YAML 文件。
但 YAML 配置管理往往充满风险:
“运维人员常说:‘YAML 是 Kubernetes 的灵魂,但也是运维事故的导火索。’”
版本管理缺失
变更审计不透明
手工变更风险高
变更回滚复杂
目标:通过YAML 管理服务,将 Kubernetes YAML 配置的版本管理、变更审计、回滚机制 和 可视化管理 集中整合到平台中,降低人为操作风险,提升变更效率和安全性。如下所示:
经过三期建设,白屏化运维平台已从概念验证逐步发展成为覆盖全场景运维的高效工具,取得了显著的成果和收益,主要体现在以下几个方面:
在三期的建设和落地过程中,我们积累了宝贵的经验,也发现了一些可以优化和提升的空间。以下是关键经验和反思:
白屏化运维平台的未来,将持续以“标准化、可视化、智能化”为核心,不断拓展运维场景,降低运维门槛,提升运维效率与安全性。
文 / 初澜
关注得物技术,每周更新技术干货
要是觉得文章对你有帮助的话,欢迎评论转发点赞~
未经得物技术许可严禁转载,否则依法追究法律责任。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。