最佳免费股票筛选 API

from decimal import Decimal, InvalidOperation
import requests


FILTERS = {
    "as_of": "2026-06-30",
    "security_type": "common_stock",
    "country": "US",
    "filters": [
        {"field": "market_cap_usd", "op": "gte", "value": 1_000_000_000},
        {"field": "ttm_revenue_growth", "op": "gt", "value": 0.10},
        {"field": "avg_dollar_volume_20d_usd", "op": "gte", "value": 5_000_000},
    ],
    "sort": ["market_cap_usd:desc", "security_id:asc"],
    "limit": 100,
}


def as_decimal(row, field):
    value = row.get(field)
    if value is None:
        return None
    try:
        return Decimal(str(value))
    except InvalidOperation as exc:
        raise ValueError(f"{field} is not numeric: {value!r}") from exc


def fetch_screen(endpoint, api_key):
    cursor = None
    snapshot = None
    seen = set()
    matches = []

    with requests.Session() as session:
        while True:
            body = {**FILTERS, "cursor": cursor}
            response = session.post(
                endpoint,
                headers={"Authorization": f"Bearer {api_key}"},
                json=body,
                timeout=(5, 30),
            )
            response.raise_for_status()
            payload = response.json()

            page_snapshot = payload.get("snapshot")
            snapshot = snapshot or page_snapshot
            if page_snapshot != snapshot:
                raise RuntimeError("Provider snapshot changed during pagination")

            for row in payload.get("results", []):
                identity = (row.get("security_id"), row.get("exchange"))
                if not all(identity):
                    raise ValueError("Stable security_id and exchange are required")
                if identity in seen:
                    raise ValueError(f"Duplicate security across pages: {identity}")
                seen.add(identity)

                cap = as_decimal(row, "market_cap_usd")
                growth = as_decimal(row, "ttm_revenue_growth")
                liquidity = as_decimal(row, "avg_dollar_volume_20d_usd")
                if None in (cap, growth, liquidity):
                    continue
                if cap >= 1_000_000_000 and growth > Decimal("0.10") \
                        and liquidity >= 5_000_000:
                    matches.append(row)

            cursor = payload.get("next_cursor")
            if not cursor:
                return matches