如何设计一个高可用的代理IP健康检查系统？

import requests
import socket
from datetime import datetime

def check_proxy_health(proxy, target_url="https://httpbin.org/ip"):
    """
    代理IP初检核心函数
    :param proxy: 代理格式 {"http": "http://ip:port", "https": "https://ip:port"}
    :param target_url: 检测目标地址（建议用httpbin.org获取真实出口IP）
    :return: 检测结果（bool）+ 延迟（ms）+ 匿名度（str）
    """
    # 1. 基础连通性检测（TCP握手）
    ip, port = proxy["http"].split("//")[-1].split(":")
    try:
        socket.create_connection((ip, int(port)), timeout=1)
    except Exception:
        return False, 0, "unreachable"
    
    # 2. 响应速度与匿名度检测
    try:
        start = datetime.now()
        response = requests.get(target_url, proxies=proxy, timeout=5)
        delay = (datetime.now() - start).total_seconds() * 1000  # 转为ms
        # 匿名度判断：对比响应中的出口IP与本地IP
        local_ip = requests.get(target_url, timeout=3).json()["origin"]
        proxy_ip = response.json()["origin"]
        if local_ip in proxy_ip:
            anonymity = "transparent"  # 透明代理（泄露真实IP）
        elif "," in proxy_ip:
            anonymity = "anonymous"    # 普通匿名
        else:
            anonymity = "high_anonymous"  # 高匿代理
        return True, round(delay, 2), anonymity
    except Exception:
        return False, 0, "invalid"

# 调用示例
proxy = {"http": "http://127.0.0.1:8080", "https": "https://127.0.0.1:8080"}
is_available, delay, anonymity = check_proxy_health(proxy)
if is_available and delay <= 2000 and anonymity == "high_anonymous":
    print("代理合格，可入库")
else:
    print("代理不合格，剔除")

def calculate_health_score(proxy_stats):
    """
    计算代理IP健康分数
    :param proxy_stats: 代理状态字典，包含各指标数据
    :return: 健康分数（0-100）
    """
    score = 0
    # 1. 基础连通性（20分）
    score += 20 if proxy_stats["reachable"] else 0
    # 2. 响应速度（20分，延迟≤2000ms得满分，每超500ms扣5分）
    delay = proxy_stats["delay"]
    score += min(20, 20 - ((delay - 2000) // 500) * 5) if delay > 0 else 0
    # 3. 匿名度（20分，高匿20分，普通匿名10分，透明0分）
    anonymity_score = {"high_anonymous":20, "anonymous":10, "transparent":0}
    score += anonymity_score.get(proxy_stats["anonymity"], 0)
    # 4. 请求成功率（30分，≥98%得满分，每降1%扣3分）
    success_rate = proxy_stats["success_rate"]
    score += min(30, 30 - ((98 - success_rate) // 1) * 3) if success_rate > 0 else 0
    # 5. 持久性（10分，有效时长≥30分钟得满分，每少5分钟扣2分）
    duration = proxy_stats["duration"]  # 单位：分钟
    score += min(10, 10 - ((30 - duration) // 5) * 2) if duration > 0 else 0
    return max(0, score)  # 分数不低于0

# 定时探活（APScheduler示例）
from apscheduler.schedulers.background import BackgroundScheduler

scheduler = BackgroundScheduler()
# 每30秒轻量检测（仅连通性）
scheduler.add_job(check_proxy_reachable, "interval", seconds=30, args=[proxy_pool])
# 每5分钟全量检测（计算健康分数）
scheduler.add_job(check_proxy_full, "interval", minutes=5, args=[proxy_pool])
scheduler.start()