API 数据采集 — 大规模可靠

import requests
from concurrent.futures import ThreadPoolExecutor

# Configure rotating proxy
proxy = {
    'http': 'http://user:pass@gate.proxyhat.com:7777',
    'https': 'http://user:pass@gate.proxyhat.com:7777'
}

def fetch_api(endpoint):
    response = requests.get(
        f'https://api.example.com/{endpoint}',
        proxies=proxy,
        timeout=30
    )
    return response.json()

# Parallel API collection
endpoints = ['products', 'prices', 'inventory']
with ThreadPoolExecutor(max_workers=10) as executor:
    results = list(executor.map(fetch_api, endpoints))