用于按美国接入网络进行 ISP 性能研究的代理

# Baseline for a network study: one slow sample per access type in one city.
# It times a tiny request through each exit and records the origin ASN.
import csv
import sys
import time
from datetime import datetime, timezone

import requests

GATEWAY = "gw.broadbandproxies.com"
PORT = 7777
PASSWORD = "PASSWORD"
CITY = "country-us-state-nc-city-charlotte"
NETWORKS = {"cable": 11426, "fiber_or_copper": 7018, "fixed_wireless": 21928}
PAUSE_SECONDS = 30

writer = csv.writer(sys.stdout)
writer.writerow(["utc_time", "access_type", "asked_asn", "exit_ip", "origin_asns", "ipify_ms"])

for access_type, asn in NETWORKS.items():
    user = "USERNAME-%s-asn-%d" % (CITY, asn)
    proxy = "http://%s:%s@%s:%d" % (user, PASSWORD, GATEWAY, PORT)
    started = time.perf_counter()
    reply = requests.get("https://api.ipify.org?format=json",
                         proxies={"http": proxy, "https": proxy}, timeout=30)
    elapsed_ms = round((time.perf_counter() - started) * 1000)
    ip = reply.json()["ip"]
    ripe = requests.get("https://stat.ripe.net/data/prefix-overview/data.json",
                        params={"resource": ip, "sourceapp": "isp-research"},
                        timeout=30).json()
    origins = " ".join("AS%d" % a["asn"] for a in ripe["data"].get("asns", []))
    writer.writerow([datetime.now(timezone.utc).isoformat(timespec="seconds"),
                     access_type, asn, ip, origins, elapsed_ms])
    time.sleep(PAUSE_SECONDS)