python flusk 監控

# 創建虛擬環境目錄 python3 -m venv /sda1/xunjian/venv # 激活虛擬環境 source /sda1/xunjian/venv/bin/activate # 激活后終端會顯示 (venv)

創建虛擬環境（在當前目錄）：
bash
python3 -m venv venv
激活虛擬環境：
bash
source venv/bin/activate  # 激活后終端會顯示 (venv)
在虛擬環境中安裝依賴（此時無權限限制）：
bash
pip install flask psutil
運行腳本（需在虛擬環境中）：
bash
python xun.py
完成后，若要退出虛擬環境，執行：
bash
deactivate
虛擬環境能完全隔離項目依賴，避免影響系統 Python 環境，是標準且安全的做法。

安裝依賴（在虛擬環境中）：

pip install flask paramiko

import psutil
import subprocess
import time
import paramiko
from flask import Flask, render_template_string, jsonify
from threading import Thread, Lockapp = Flask(__name__)
lock = Lock()# 監控配置：本地 + 遠程機器（修改遠程機器SSH信息）
MONITOR_CONFIG = {"local": {"name": "本地服務器","type": "local"},"remote-1": {"name": "遠程服務器 (192.168.1.7)","type": "remote","ip": "192.168.1.7","username": "your_ssh_username",  # 替換為遠程SSH用戶名"password": "your_ssh_password",  # 替換為遠程SSH密碼"services": ["nginx", "mysql", "ssh"]  # 遠程監控服務}
}# 本地監控服務列表
LOCAL_SERVICES = ["nginx", "mysql", "docker"]# -------------------------- 工具函數：單位轉換（核心修復） --------------------------
def convert_to_gb(value_str):"""將帶單位的存儲值（如462M、2.5G）轉換為GB的浮點數"""if not value_str:return 0.0value_str = value_str.strip().upper()if 'G' in value_str:return float(value_str.replace('G', ''))elif 'M' in value_str:return float(value_str.replace('M', '')) / 1024  # M轉Gelif 'K' in value_str:return float(value_str.replace('K', '')) / (1024 **2)  # K轉Gelse:return 0.0# -------------------------- 本地機器監控 --------------------------
def get_local_system_info():"""獲取本地系統資源信息（修復狀態判斷）"""# CPUcpu_percent = psutil.cpu_percent(interval=1)cpu_cores = psutil.cpu_count(logical=False)# 內存memory = psutil.virtual_memory()memory_used = round(memory.used / (1024** 3), 2)memory_total = round(memory.total / (1024 **3), 2)# 磁盤（根目錄）disk = psutil.disk_usage('/')disk_used = round(disk.used / (1024** 3), 2)disk_total = round(disk.total / (1024 **3), 2)# Swapswap = psutil.swap_memory()swap_used = round(swap.used / (1024** 3), 2)swap_total = round(swap.total / (1024 **3), 2)return {"cpu": {"percent": cpu_percent, "cores": cpu_cores},"memory": {"used": memory_used, "total": memory_total, "percent": memory.percent},"disk": {"used": disk_used, "total": disk_total, "percent": disk.percent},"swap": {"used": swap_used, "total": swap_total, "percent": swap.percent}}def check_local_service_status(service):"""檢查本地服務狀態"""try:result = subprocess.run(f"systemctl is-active {service}",shell=True,capture_output=True,text=True)return result.stdout.strip() == "active"except:for p in psutil.process_iter(["name"]):if service in p.info["name"].lower():return Truereturn False# -------------------------- 遠程機器監控（核心修復） --------------------------
def ssh_exec_command(ip, username, password, command):"""通過SSH執行遠程命令"""ssh = paramiko.SSHClient()ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())try:ssh.connect(ip, username=username, password=password, timeout=10)stdin, stdout, stderr = ssh.exec_command(command)output = stdout.read().decode().strip()error = stderr.read().decode().strip()return output, errorexcept Exception as e:return None, str(e)finally:ssh.close()def get_remote_system_info(config):"""獲取遠程系統資源信息（修復單位轉換錯誤）"""ip = config["ip"]username = config["username"]password = config["password"]# CPU使用率（修復命令，兼容更多系統）cpu_output, err = ssh_exec_command(ip, username, password, "grep 'cpu ' /proc/stat | awk '{usage=($2+$4)*100/($2+$4+$5)} END {print usage}'")cpu_percent = float(cpu_output) if cpu_output and cpu_output.replace('.', '', 1).isdigit() else 0.0# 內存信息（處理M/GB單位）mem_output, err = ssh_exec_command(ip, username, password, "free -h | grep Mem | awk '{print $3, $2}'"  # 只取已用和總量（如"462M 1.8G"）)mem_used = 0.0mem_total = 0.0mem_percent = 0.0if mem_output and len(mem_output.split()) == 2:mem_used_str, mem_total_str = mem_output.split()mem_used = convert_to_gb(mem_used_str)mem_total = convert_to_gb(mem_total_str)mem_percent = (mem_used / mem_total) * 100 if mem_total > 0 else 0.0# 磁盤信息（處理M/GB單位）disk_output, err = ssh_exec_command(ip, username, password, "df -h / | tail -1 | awk '{print $3, $2}'"  # 已用和總量（如"5.8G 6.3G"）)disk_used = 0.0disk_total = 0.0disk_percent = 0.0if disk_output and len(disk_output.split()) == 2:disk_used_str, disk_total_str = disk_output.split()disk_used = convert_to_gb(disk_used_str)disk_total = convert_to_gb(disk_total_str)disk_percent = (disk_used / disk_total) * 100 if disk_total > 0 else 0.0# Swap信息（處理M/GB單位）swap_output, err = ssh_exec_command(ip, username, password, "free -h | grep Swap | awk '{print $3, $2}'")swap_used = 0.0swap_total = 0.0swap_percent = 0.0if swap_output and len(swap_output.split()) == 2:swap_used_str, swap_total_str = swap_output.split()swap_used = convert_to_gb(swap_used_str)swap_total = convert_to_gb(swap_total_str)swap_percent = (swap_used / swap_total) * 100 if swap_total > 0 else 0.0return {"cpu": {"percent": round(cpu_percent, 1), "cores": 0},"memory": {"used": round(mem_used, 2), "total": round(mem_total, 2), "percent": round(mem_percent, 1)},"disk": {"used": round(disk_used, 2), "total": round(disk_total, 2), "percent": round(disk_percent, 1)},"swap": {"used": round(swap_used, 2), "total": round(swap_total, 2), "percent": round(swap_percent, 1)}}def check_remote_service_status(config, service):"""檢查遠程服務狀態（確保返回布爾值）"""ip = config["ip"]username = config["username"]password = config["password"]# 先檢查systemctl狀態output, err = ssh_exec_command(ip, username, password, f"systemctl is-active {service}")if output == "active":return True# 再檢查進程output, err = ssh_exec_command(ip, username, password, f"pgrep -x {service} >/dev/null 2>&1 && echo 'running'")return output == "running"# -------------------------- 數據更新線程 --------------------------
def update_monitor_data():"""定期更新所有機器的監控數據（修復狀態顯示）"""while True:with lock:# 本地機器數據（明確標記為online）try:local_system = get_local_system_info()local_services = [{"name": s, "is_running": check_local_service_status(s)}for s in LOCAL_SERVICES]monitor_data["local"] = {"name": MONITOR_CONFIG["local"]["name"],"system": local_system,"services": local_services,"update_time": time.strftime('%Y-%m-%d %H:%M:%S'),"status": "online"  # 本地默認在線}except Exception as e:monitor_data["local"] = {"name": MONITOR_CONFIG["local"]["name"],"error": str(e),"status": "offline","update_time": time.strftime('%Y-%m-%d %H:%M:%S')}# 遠程機器數據（完善錯誤處理）remote_config = MONITOR_CONFIG["remote-1"]try:remote_system = get_remote_system_info(remote_config)# 確保服務列表不為空remote_services = []for s in remote_config["services"]:try:remote_services.append({"name": s,"is_running": check_remote_service_status(remote_config, s)})except:remote_services.append({"name": s,"is_running": False})monitor_data["remote-1"] = {"name": remote_config["name"],"system": remote_system,"services": remote_services,"update_time": time.strftime('%Y-%m-%d %H:%M:%S'),"status": "online"}except Exception as e:# 即使出錯，也返回空服務列表避免前端undefinedmonitor_data["remote-1"] = {"name": remote_config["name"],"error": f"連接失敗: {str(e)}","services": [{"name": s, "is_running": False} for s in remote_config["services"]],"status": "offline","update_time": time.strftime('%Y-%m-%d %H:%M:%S')}time.sleep(10)  # 每10秒更新一次# 初始化監控數據存儲
monitor_data = {}
# 啟動更新線程
update_thread = Thread(target=update_monitor_data, daemon=True)
update_thread.start()# -------------------------- Web頁面與API --------------------------
@app.route('/')
def index():return render_template_string('''
<!DOCTYPE html>
<html lang="zh-CN">
<head><meta charset="UTF-8"><title>多機器監控儀表盤</title><script src="https://cdn.tailwindcss.com"></script><link href="https://cdn.jsdelivr.net/npm/font-awesome@4.7.0/css/font-awesome.min.css" rel="stylesheet"><style>.machine-card {border: 1px solid #e2e8f0;border-radius: 0.5rem;padding: 1rem;margin-bottom: 1rem;}.status-running { color: #10b981; }.status-stopped { color: #ef4444; }.status-online { color: #10b981; }.status-offline { color: #ef4444; }</style>
</head>
<body class="bg-gray-50 p-4"><h1 class="text-2xl font-bold mb-6">多機器監控儀表盤</h1><div id="monitor-data"><!-- 數據將通過JS動態填充 --></div><script>function formatData() {fetch('/api/data').then(res => res.json()).then(data => {let html = '';for (let key in data) {const machine = data[key];// 處理未定義的系統數據const system = machine.system || {cpu: {percent: 0},memory: {used: 0, total: 0},disk: {used: 0, total: 0},swap: {used: 0, total: 0}};// 處理未定義的服務const services = machine.services || [];html += `<div class="machine-card"><h2 class="text-xl font-semibold mb-4">${machine.name} <span class="text-sm ml-2 ${machine.status === 'online' ? 'status-online' : 'status-offline'}">${machine.status === 'online' ? '在線' : '離線'}</span></h2>${machine.error ? `<p class="text-red-500 mb-4 text-sm">${machine.error}</p>` : ''}<div class="grid grid-cols-1 md:grid-cols-4 gap-4 mb-6"><div class="bg-white p-3 rounded shadow"><h3 class="text-sm text-gray-500">CPU使用率</h3><p class="text-xl font-bold">${system.cpu.percent.toFixed(1)}%</p></div><div class="bg-white p-3 rounded shadow"><h3 class="text-sm text-gray-500">內存使用</h3><p class="text-xl font-bold">${system.memory.used.toFixed(2)}G/${system.memory.total.toFixed(2)}G</p></div><div class="bg-white p-3 rounded shadow"><h3 class="text-sm text-gray-500">磁盤使用</h3><p class="text-xl font-bold">${system.disk.used.toFixed(2)}G/${system.disk.total.toFixed(2)}G</p></div><div class="bg-white p-3 rounded shadow"><h3 class="text-sm text-gray-500">Swap使用</h3><p class="text-xl font-bold">${system.swap.used.toFixed(2)}G/${system.swap.total.toFixed(2)}G</p></div></div><div class="mb-2"><h3 class="text-lg font-medium mb-2">服務狀態</h3><div class="grid grid-cols-1 sm:grid-cols-2 md:grid-cols-3 gap-2">${services.map(s => `<div class="bg-white p-2 rounded shadow flex justify-between items-center"><span>${s.name}</span><span class="${s.is_running ? 'status-running' : 'status-stopped'}"><i class="fa ${s.is_running ? 'fa-check-circle' : 'fa-times-circle'}"></i>${s.is_running ? '運行中' : '已停止'}</span></div>`).join('')}</div></div><p class="text-xs text-gray-500">最后更新: ${machine.update_time}</p></div>`;}document.getElementById('monitor-data').innerHTML = html;});}// 初始加載和定時刷新formatData();setInterval(formatData, 10000);</script>
</body>
</html>''')@app.route('/api/data')
def api_data():with lock:return jsonify(monitor_data)if __name__ == '__main__':app.run(host='0.0.0.0', port=5000, debug=True)