Spaces:
Running
Running
| """MoltBot 状态监控网页""" | |
| import json | |
| import os | |
| import subprocess | |
| import time | |
| from datetime import datetime, timedelta | |
| import psutil | |
| from flask import Flask, Response | |
| app = Flask(__name__) | |
| START_TIME = time.time() | |
| def get_gateway_status(): | |
| """检查 OpenClaw Gateway 是否在运行""" | |
| for proc in psutil.process_iter(["pid", "name", "cmdline"]): | |
| try: | |
| cmdline = " ".join(proc.info.get("cmdline") or []) | |
| if "openclaw" in cmdline and "gateway" in cmdline: | |
| return {"running": True, "pid": proc.info["pid"]} | |
| except (psutil.NoSuchProcess, psutil.AccessDenied): | |
| continue | |
| return {"running": False, "pid": None} | |
| def get_feishu_status(): | |
| """检查飞书连接状态（通过日志）""" | |
| log_file = f"/tmp/openclaw/openclaw-{datetime.now().strftime('%Y-%m-%d')}.log" | |
| if not os.path.exists(log_file): | |
| return "unknown" | |
| try: | |
| result = subprocess.run( | |
| ["tail", "-100", log_file], | |
| capture_output=True, text=True, timeout=5 | |
| ) | |
| lines = result.stdout | |
| if "[feishu]" in lines: | |
| if "ws client ready" in lines or "Received from" in lines: | |
| return "connected" | |
| elif "auto-restart" in lines: | |
| return "reconnecting" | |
| return "initializing" | |
| except Exception: | |
| return "unknown" | |
| def get_message_count(): | |
| """统计今日消息数""" | |
| log_file = f"/tmp/openclaw/openclaw-{datetime.now().strftime('%Y-%m-%d')}.log" | |
| if not os.path.exists(log_file): | |
| return 0 | |
| try: | |
| result = subprocess.run( | |
| ["grep", "-c", "Received from", log_file], | |
| capture_output=True, text=True, timeout=5 | |
| ) | |
| return int(result.stdout.strip() or 0) | |
| except Exception: | |
| return 0 | |
| def get_system_info(): | |
| """获取系统资源信息""" | |
| uptime = timedelta(seconds=int(time.time() - START_TIME)) | |
| return { | |
| "cpu_percent": psutil.cpu_percent(interval=0.5), | |
| "memory": psutil.virtual_memory()._asdict(), | |
| "uptime": str(uptime), | |
| } | |
| def format_bytes(b): | |
| """格式化字节""" | |
| for unit in ["B", "KB", "MB", "GB"]: | |
| if b < 1024: | |
| return f"{b:.1f} {unit}" | |
| b /= 1024 | |
| return f"{b:.1f} TB" | |
| STATUS_COLORS = { | |
| "connected": "#00e676", | |
| "reconnecting": "#ffc107", | |
| "initializing": "#2196f3", | |
| "unknown": "#9e9e9e", | |
| } | |
| STATUS_TEXT = { | |
| "connected": "✅ 已连接", | |
| "reconnecting": "🔄 重连中", | |
| "initializing": "⏳ 初始化中", | |
| "unknown": "❓ 未知", | |
| } | |
| def index(): | |
| gw = get_gateway_status() | |
| feishu = get_feishu_status() | |
| msgs = get_message_count() | |
| sys_info = get_system_info() | |
| mem = sys_info["memory"] | |
| feishu_color = STATUS_COLORS.get(feishu, "#9e9e9e") | |
| feishu_text = STATUS_TEXT.get(feishu, "❓ 未知") | |
| gw_color = "#00e676" if gw["running"] else "#f44336" | |
| gw_text = f"✅ 运行中 (PID {gw['pid']})" if gw["running"] else "❌ 已停止" | |
| html = f"""<!DOCTYPE html> | |
| <html lang="zh-CN"> | |
| <head> | |
| <meta charset="UTF-8"> | |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> | |
| <meta http-equiv="refresh" content="30"> | |
| <title>MoltBot 状态监控</title> | |
| <style> | |
| * {{ margin: 0; padding: 0; box-sizing: border-box; }} | |
| body {{ | |
| font-family: 'Segoe UI', -apple-system, BlinkMacSystemFont, sans-serif; | |
| background: linear-gradient(135deg, #0f0c29, #302b63, #24243e); | |
| min-height: 100vh; | |
| color: #e0e0e0; | |
| padding: 20px; | |
| }} | |
| .container {{ max-width: 800px; margin: 0 auto; }} | |
| .header {{ | |
| text-align: center; | |
| padding: 40px 20px 30px; | |
| }} | |
| .header h1 {{ | |
| font-size: 2.2em; | |
| background: linear-gradient(135deg, #667eea, #764ba2); | |
| -webkit-background-clip: text; | |
| -webkit-text-fill-color: transparent; | |
| margin-bottom: 8px; | |
| }} | |
| .header p {{ color: #9e9e9e; font-size: 0.95em; }} | |
| .cards {{ display: grid; grid-template-columns: 1fr 1fr; gap: 16px; margin-top: 24px; }} | |
| .card {{ | |
| background: rgba(255,255,255,0.06); | |
| backdrop-filter: blur(12px); | |
| border: 1px solid rgba(255,255,255,0.08); | |
| border-radius: 16px; | |
| padding: 24px; | |
| transition: transform 0.2s, box-shadow 0.2s; | |
| }} | |
| .card:hover {{ | |
| transform: translateY(-2px); | |
| box-shadow: 0 8px 32px rgba(102,126,234,0.15); | |
| }} | |
| .card-title {{ | |
| font-size: 0.85em; | |
| color: #9e9e9e; | |
| text-transform: uppercase; | |
| letter-spacing: 1px; | |
| margin-bottom: 12px; | |
| }} | |
| .card-value {{ | |
| font-size: 1.4em; | |
| font-weight: 600; | |
| }} | |
| .status-dot {{ | |
| display: inline-block; | |
| width: 10px; height: 10px; | |
| border-radius: 50%; | |
| margin-right: 8px; | |
| animation: pulse 2s infinite; | |
| }} | |
| @keyframes pulse {{ | |
| 0%, 100% {{ opacity: 1; }} | |
| 50% {{ opacity: 0.5; }} | |
| }} | |
| .card-full {{ grid-column: 1 / -1; }} | |
| .stats-grid {{ display: grid; grid-template-columns: repeat(3, 1fr); gap: 12px; margin-top: 12px; }} | |
| .stat {{ text-align: center; }} | |
| .stat-value {{ font-size: 1.6em; font-weight: 700; color: #667eea; }} | |
| .stat-label {{ font-size: 0.8em; color: #9e9e9e; margin-top: 4px; }} | |
| .progress-bar {{ | |
| width: 100%; | |
| height: 8px; | |
| background: rgba(255,255,255,0.1); | |
| border-radius: 4px; | |
| margin-top: 8px; | |
| overflow: hidden; | |
| }} | |
| .progress-fill {{ | |
| height: 100%; | |
| border-radius: 4px; | |
| transition: width 0.5s; | |
| }} | |
| .footer {{ | |
| text-align: center; | |
| padding: 30px; | |
| color: #616161; | |
| font-size: 0.85em; | |
| }} | |
| @media (max-width: 600px) {{ | |
| .cards {{ grid-template-columns: 1fr; }} | |
| .stats-grid {{ grid-template-columns: 1fr; }} | |
| }} | |
| </style> | |
| </head> | |
| <body> | |
| <div class="container"> | |
| <div class="header"> | |
| <h1>🤖 MoltBot AI</h1> | |
| <p>飞书智能助手 · 状态监控</p> | |
| </div> | |
| <div class="cards"> | |
| <div class="card"> | |
| <div class="card-title">OpenClaw 网关</div> | |
| <div class="card-value"> | |
| <span class="status-dot" style="background:{gw_color}"></span> | |
| {gw_text} | |
| </div> | |
| </div> | |
| <div class="card"> | |
| <div class="card-title">飞书连接</div> | |
| <div class="card-value"> | |
| <span class="status-dot" style="background:{feishu_color}"></span> | |
| {feishu_text} | |
| </div> | |
| </div> | |
| <div class="card card-full"> | |
| <div class="card-title">系统概览</div> | |
| <div class="stats-grid"> | |
| <div class="stat"> | |
| <div class="stat-value">{sys_info['uptime']}</div> | |
| <div class="stat-label">运行时长</div> | |
| </div> | |
| <div class="stat"> | |
| <div class="stat-value">{msgs}</div> | |
| <div class="stat-label">今日消息</div> | |
| </div> | |
| <div class="stat"> | |
| <div class="stat-value">{os.environ.get('MODEL_NAME', 'N/A')}</div> | |
| <div class="stat-label">当前模型</div> | |
| </div> | |
| </div> | |
| </div> | |
| <div class="card"> | |
| <div class="card-title">CPU 使用率</div> | |
| <div class="card-value">{sys_info['cpu_percent']}%</div> | |
| <div class="progress-bar"> | |
| <div class="progress-fill" style="width:{sys_info['cpu_percent']}%;background:linear-gradient(90deg,#667eea,#764ba2)"></div> | |
| </div> | |
| </div> | |
| <div class="card"> | |
| <div class="card-title">内存使用</div> | |
| <div class="card-value">{format_bytes(mem['used'])} / {format_bytes(mem['total'])}</div> | |
| <div class="progress-bar"> | |
| <div class="progress-fill" style="width:{mem['percent']}%;background:linear-gradient(90deg,#00e676,#00c853)"></div> | |
| </div> | |
| </div> | |
| </div> | |
| <div class="footer"> | |
| 最后更新: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')} · 自动刷新 30s | |
| </div> | |
| </div> | |
| </body> | |
| </html>""" | |
| return Response(html, content_type="text/html; charset=utf-8") | |
| def health(): | |
| gw = get_gateway_status() | |
| return json.dumps({ | |
| "status": "ok" if gw["running"] else "error", | |
| "gateway": gw, | |
| "feishu": get_feishu_status(), | |
| "uptime": time.time() - START_TIME, | |
| }), 200 if gw["running"] else 503 | |
| if __name__ == "__main__": | |
| app.run(host="0.0.0.0", port=7860) | |