forked from DevOps/deploy.stack
648faac289
实现一个基于Golang的MCP时间服务器，提供获取当前时间和日期功能 包含客户端示例、安装脚本和详细文档 refactor: 优化磁盘巡检脚本以支持SAS和SSD硬盘 增强磁盘巡检脚本的兼容性，改进SMART信息解析逻辑 添加硬盘类型检测和更全面的错误处理 docs: 更新README和安装说明 添加MCP时间服务器的使用文档和API说明 完善磁盘巡检报告格式和内容
171 lines
6.5 KiB
Python
171 lines
6.5 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
import re
|
||
|
||
# 提取服务信息的函数
|
||
def extract_service_info(file_path):
|
||
"""从文件中提取服务信息，返回服务名称和镜像的字典"""
|
||
services = {}
|
||
|
||
with open(file_path, 'r', encoding='utf-8') as f:
|
||
lines = f.readlines()
|
||
|
||
# 跳过表头
|
||
for line in lines[2:]:
|
||
if line.strip():
|
||
# 使用固定宽度解析每行数据
|
||
try:
|
||
# 从固定位置提取各字段
|
||
name_part = line[12:42].strip() # 服务名称
|
||
image_part = line[70:136].strip() # 镜像名称
|
||
|
||
# 只有当name和image都有值时才添加
|
||
if name_part and image_part:
|
||
# 保存原始名称和镜像
|
||
services[name_part] = image_part
|
||
except Exception as e:
|
||
print(f"解析行时出错: {line.strip()}, 错误: {e}")
|
||
|
||
return services
|
||
|
||
def normalize_service_name(service_name):
|
||
"""标准化服务名称，移除环境前缀，处理大小写和分隔符差异"""
|
||
# 转换为小写以处理大小写差异
|
||
normalized = service_name.lower()
|
||
|
||
# Blue环境的服务名称处理
|
||
blue_patterns = [
|
||
'blue-php_', 'blue-ppos_', 'blue_api_', 'blue_web_'
|
||
]
|
||
for pattern in blue_patterns:
|
||
if normalized.startswith(pattern.lower()):
|
||
normalized = normalized[len(pattern):]
|
||
break
|
||
|
||
# Green环境的服务名称处理
|
||
green_patterns = [
|
||
'papacore_', 'pposmix_', 'cron_', 'dataserv_', 'imgser_', 'ppcscore_'
|
||
]
|
||
for pattern in green_patterns:
|
||
if normalized.startswith(pattern.lower()):
|
||
normalized = normalized[len(pattern):]
|
||
break
|
||
|
||
# 替换所有分隔符为下划线，统一格式
|
||
normalized = re.sub(r'[-_]+', '_', normalized)
|
||
|
||
# 移除可能的前后空格
|
||
normalized = normalized.strip('_')
|
||
|
||
return normalized
|
||
|
||
def compare_services(blue_services, green_services):
|
||
"""比较两个环境中的服务镜像"""
|
||
# 1. blue_services 已经是 name 为 key，image 为值的字典对象
|
||
# 2. green_services 已经是 name 为 key，image 为值的字典对象
|
||
|
||
# 创建标准化名称到原始名称和镜像的映射
|
||
blue_norm_map = {normalize_service_name(name): (name, image) for name, image in blue_services.items()}
|
||
green_norm_map = {normalize_service_name(name): (name, image) for name, image in green_services.items()}
|
||
|
||
|
||
# print(blue_norm_map)
|
||
print("=" * 80)
|
||
print(green_norm_map)
|
||
|
||
# 显示所有Blue和Green环境的服务镜像对比
|
||
print("=== Blue环境与Green环境服务镜像详细对比 ===")
|
||
print("{:<35} {:<65} {:<65}".format("服务名称", "Blue镜像", "Green镜像"))
|
||
print("=" * 80)
|
||
|
||
# 统计变量
|
||
different_count = 0
|
||
same_count = 0
|
||
|
||
# 创建数组用于存储更新命令
|
||
update_commands = []
|
||
|
||
# 遍历Blue环境中的每个服务（使用标准化名称进行比较）
|
||
for norm_name, (blue_name, blue_image) in blue_norm_map.items():
|
||
# 初始化green_name和green_image为默认值
|
||
green_name = "-" # 表示未找到对应服务
|
||
green_image = "-"
|
||
|
||
# if norm_name == "member_middleplatform":
|
||
# green_name, green_image = green_norm_map.get("ppos_member_middlepla", ("未找到", ""))
|
||
|
||
# if norm_name == "device_api":
|
||
# green_name, green_image = green_norm_map.get("ppos_device_api", ("未找到", ""))
|
||
|
||
# if norm_name == "events-api":
|
||
# green_name, green_image = green_norm_map.get("ppos_events_api", ("未找到", ""))
|
||
|
||
# if norm_name == "ac-api":
|
||
# green_name, green_image = green_norm_map.get("ppos_ac_api", ("未找到", ""))
|
||
|
||
|
||
if norm_name in green_norm_map:
|
||
green_name, green_image = green_norm_map[norm_name]
|
||
|
||
print(norm_name, blue_name, green_name)
|
||
|
||
# 查找Green环境中是否有相同标准化名称的服务
|
||
#if norm_name in green_norm_map:
|
||
# 打印Blue中与Green不同的服务
|
||
# if blue_image != green_image:
|
||
# print("{:<35} {:<65} {:<65}".format(
|
||
# blue_name[:30] + "..." if len(blue_name) > 30 else blue_name,
|
||
# blue_image[:60] + "..." if len(blue_image) > 60 else blue_image,
|
||
# green_image[:60] + "..." if len(green_image) > 60 else green_image
|
||
# ))
|
||
# # 生成更新命令并添加到数组中
|
||
# update_command = generate_update_command(blue_name, green_image)
|
||
# update_commands.append(update_command)
|
||
# different_count += 1
|
||
# else:
|
||
# same_count += 1
|
||
|
||
# # 显示Green环境中特有但Blue环境没有的服务
|
||
# print()
|
||
# print("=== Green环境中特有但Blue环境没有的服务 ===")
|
||
# for norm_name, (green_name, green_image) in green_norm_map.items():
|
||
# if norm_name not in blue_norm_map:
|
||
# print("{:<35} {:<65}".format(
|
||
# green_name[:30] + "..." if len(green_name) > 30 else green_name,
|
||
# green_image[:60] + "..." if len(green_image) > 60 else green_image
|
||
# ))
|
||
|
||
# # 打印所有更新命令
|
||
# if update_commands:
|
||
# print()
|
||
# print("=== 推荐的更新命令 ===")
|
||
# for command in update_commands:
|
||
# print(command)
|
||
|
||
# print()
|
||
# print(f"Blue和Green环境中名称相同但镜像不同的服务总数: {different_count}")
|
||
# print(f"Blue和Green环境中名称相同且镜像相同的服务总数: {same_count}")
|
||
|
||
# 添加一个函数 生成`docker service update --force --image hub.wesais.cn/ppos-pro/pposorder:v.250910.1819 blue-ppos_PPOSOrder`
|
||
def generate_update_command(service_name, image):
|
||
"""生成更新服务镜像的命令"""
|
||
return f"docker service update --force --image {image} {service_name}"
|
||
|
||
|
||
|
||
def main():
|
||
"""主函数，比较两个环境中的服务镜像"""
|
||
blue_path = '/home/geng/mydate/deploy.stack/g-b/blue'
|
||
green_path = '/home/geng/mydate/deploy.stack/g-b/green'
|
||
|
||
# 提取服务信息
|
||
blue_services = extract_service_info(blue_path)
|
||
green_services = extract_service_info(green_path)
|
||
# print(blue_services)
|
||
# print(green_services)
|
||
|
||
# 比较服务镜像
|
||
compare_services(blue_services, green_services)
|
||
|
||
if __name__ == "__main__":
|
||
main() |