vps_monitor.py

import paramiko
import schedule
import time
import os
import sys
from flask import Flask, jsonify, render_template_string
from threading import Thread
import logging

app = Flask(__name__)

vps_status = {}

# 设置日志
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(levelname)s - %(message)s',
    handlers=[
        logging.StreamHandler(sys.stdout),
        logging.StreamHandler(sys.stderr)
    ]
)
logger = logging.getLogger()

def get_vps_configs():
    configs = []
    index = 1
    while True:
        hostname = os.environ.get(f'HOSTNAME_{index}')
        if not hostname:
            break
        
        username = os.environ.get(f'USERNAME_{index}')
        password = os.environ.get(f'PASSWORD_{index}')
        
        script_paths = []
        script_index = 1
        while True:
            script_path = os.environ.get(f'SCRIPT_PATHS_{index}_{script_index}')
            if not script_path:
                break
            script_paths.append(script_path.strip())
            script_index += 1
        
        for script_path in script_paths:
            config = {
                'index': index,
                'hostname': hostname,
                'username': username,
                'password': password,
                'script_path': script_path
            }
            configs.append(config)
        
        # 添加调试输出
        logger.info(f"Config {index}: {hostname}, {username}, {script_paths}")
        print(f"Config {index}: {hostname}, {username}, {script_paths}")
        sys.stdout.flush()
        
        index += 1
    return configs

def check_and_run_script(config):
    logger.info(f"Checking VPS {config['index']}: {config['hostname']} - {config['script_path']}")
    print(f"Checking VPS {config['index']}: {config['hostname']} - {config['script_path']}")
    sys.stdout.flush()
    client = None
    try:
        client = paramiko.SSHClient()
        client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        
        logger.info(f"Connecting to {config['hostname']}")
        client.connect(
            hostname=config['hostname'],
            username=config['username'],
            password=config['password'],
            port=22
        )
        
        script_path = config['script_path']
        script_name = os.path.basename(script_path)
        
        # 检查脚本是否正在运行 (使用 ps 命令，适用于FreeBSD)
        check_command = f"ps aux | grep {script_name} | grep -v grep"
        stdin, stdout, stderr = client.exec_command(check_command)
        if stdout.read():
            status = "Running"
            logger.info(f"Script {script_name} is running on {config['hostname']}")
        else:
            logger.info(f"Script {script_name} not running on {config['hostname']}. Executing restart script.")
            restart_command = f"/bin/sh {script_path}"  # 使用完整路径的sh
            stdin, stdout, stderr = client.exec_command(restart_command)
            exit_status = stdout.channel.recv_exit_status()
            
            if exit_status == 0:
                status = "Restarted"
                logger.info(f"Restart script {script_name} executed successfully on {config['hostname']}")
            else:
                error_output = stderr.read().decode('utf-8')
                status = f"Error: {error_output}"
                logger.error(f"Error executing restart script {script_name} on {config['hostname']}: {error_output}")
        
        key = f"{config['hostname']}:{script_name}"
        vps_status[key] = {
            'index': config['index'],
            'status': status,
            'last_check': time.strftime('%Y-%m-%d %H:%M:%S'),
            'username': config['username'],
            'script_name': script_name
        }
        
    except Exception as e:
        logger.error(f"Error occurred while checking VPS {config['index']} - {config['hostname']} - {script_name}: {str(e)}")
        key = f"{config['hostname']}:{script_name}"
        vps_status[key] = {
            'index': config['index'],
            'status': f"Error: {str(e)}",
            'last_check': time.strftime('%Y-%m-%d %H:%M:%S'),
            'username': config['username'],
            'script_name': script_name
        }
    finally:
        if client:
            client.close()
            logger.info(f"SSH connection closed for VPS {config['index']}: {config['hostname']}")
        logger.info(f"Finished checking VPS {config['index']}: {config['hostname']} - {script_name}")
        print(f"Finished checking VPS {config['index']}: {config['hostname']} - {script_name}")
        sys.stdout.flush()

def check_all_vps():
    logger.info("Starting VPS check")
    print("Starting VPS check")
    sys.stdout.flush()
    vps_configs = get_vps_configs()
    for config in vps_configs:
        check_and_run_script(config)
    logger.info("Finished VPS check")
    for key, status in vps_status.items():
        print(f"VPS {status['index']} - {key}: Status: {status['status']}, Username: {status['username']}, Script: {status['script_name']}")
    sys.stdout.flush()

@app.route('/')
def index():
    html = '''
    <h1>VPS Status Overview</h1>
    <table border="1">
        <tr>
            <th>Index</th>
            <th>Hostname</th>
            <th>Script Name</th>
            <th>Status</th>
            <th>Last Check</th>
            <th>Username</th>
        </tr>
        {% for key, data in vps_status.items() %}
        <tr>
            <td>{{ data.index }}</td>
            <td><a href="/status/{{ key }}">{{ key.split(':')[0] }}</a></td>
            <td>{{ data.script_name }}</td>
            <td>{{ data.status }}</td>
            <td>{{ data.last_check }}</td>
            <td>{{ data.username }}</td>
        </tr>
        {% endfor %}
    </table>
    '''
    return render_template_string(html, vps_status=vps_status)

@app.route('/status/<path:key>')
def vps_status_detail(key):
    if key in vps_status:
        return jsonify(vps_status[key])
    else:
        return jsonify({"error": "VPS or script not found"}), 404

@app.route('/health')
def health_check():
    return jsonify({"status": "healthy", "uptime": time.time() - start_time}), 200

def run_flask():
    app.run(host='0.0.0.0', port=8080)

def main():
    global start_time
    start_time = time.time()
    
    print("===== VPS monitoring script is starting =====")
    sys.stdout.flush()
    logger.info("===== VPS monitoring script started =====")
    
    flask_thread = Thread(target=run_flask)
    flask_thread.start()
    logger.info("Flask server started in background")
    print("Flask server started in background")
    sys.stdout.flush()

    vps_configs = get_vps_configs()
    logger.info(f"Found {len(vps_configs)} VPS configurations")
    print(f"Found {len(vps_configs)} VPS configurations")
    sys.stdout.flush()
    for config in vps_configs:
        logger.info(f"VPS configured: {config['hostname']} - {config['script_path']}")
        print(f"VPS configured: {config['hostname']} - {config['script_path']}")
        sys.stdout.flush()

    logger.info("Running initial VPS check")
    print("Running initial VPS check")
    sys.stdout.flush()
    check_all_vps()

    schedule.every(15).minutes.do(check_all_vps)
    logger.info("Scheduled VPS check every 15 minutes")
    print("Scheduled VPS check every 15 minutes")
    sys.stdout.flush()
    
    print("===== VPS monitoring script is running =====")
    sys.stdout.flush()
    
    heartbeat_count = 0
    while True:
        schedule.run_pending()
        time.sleep(60)
        heartbeat_count += 1
        if heartbeat_count % 5 == 0:  # 每5分钟输出一次心跳信息
            print(f"Heartbeat: Script is still running. Uptime: {heartbeat_count} minutes")
            sys.stdout.flush()

if __name__ == "__main__":
    main()