AI Agent 代理：彻底消除多工作线程间的 IP 冲突与封禁

import requests
from concurrent.futures import ThreadPoolExecutor

# BytesFlows 会话隔离逻辑：在账号后追加 "-session-{唯一ID}"
PROXY_HOST = "proxy.bytesflows.com:31112"
BASE_USER = "user-youraccount-country-us"
PASSWORD = "yourpassword"

def run_agent_task(task_id: int, url: str):
    # 每个工作线程拥有专属的独立粘性住宅 IP
    session_user = f"{BASE_USER}-session-worker_{task_id}"
    proxies = {
        "http": f"http://{session_user}:{PASSWORD}@{PROXY_HOST}",
        "https": f"http://{session_user}:{PASSWORD}@{PROXY_HOST}"
    }
    
    resp = requests.get(url, proxies=proxies, timeout=10)
    print(f"[Worker #{task_id}] 状态码: {resp.status_code} | 出口 IP: {resp.json().get('origin')}")

# 启动 5 个并发智能体线程，IP 完全独立互不影响
urls = ["https://httpbin.org/ip"] * 5
with ThreadPoolExecutor(max_workers=5) as executor:
    for i, target_url in enumerate(urls):
        executor.submit(run_agent_task, i+1, target_url)