从 AkShare 迁移到 ashareapi：接口对照与改写

# AkShare                              # ashareapi
# "600667"   （沪 A）      →   sh600667
# "000001"   （深 A）      →   sz000001
# "830799"   （北交所）    →   bj830799
# "00700"    （港股）      →   hk00700
# "AAPL"     （美股）      →   usAAPL

# 按代码首位判断市场（A 股规则）——够用但不完备，北交所/新老代码需按实际核对
def to_code(symbol: str) -> str:
    """把 AkShare 的纯数字代码转成 ashareapi 前缀式代码"""
    if not symbol.isdigit():
        return "us" + symbol.upper()          # 非数字 → 美股
    if symbol.startswith(("60", "68")):       # 沪市主板 / 科创板
        return "sh" + symbol
    if symbol.startswith(("00", "30")):        # 深市主板 / 创业板
        return "sz" + symbol
    if symbol.startswith(("83", "87", "43")):  # 北交所
        return "bj" + symbol
    return "sh" + symbol                        # 兜底（务必按实际核对）

# ── 改写前（AkShare）─────────────────────────
# import akshare as ak
# df = ak.stock_zh_a_hist(symbol="600667", period="daily",
#                         start_date="20260101", end_date="20260925",
#                         adjust="")
# print(df[["日期", "收盘", "成交量"]])

# ── 改写后（ashareapi）──────────────────────
import requests

BASE = "https://api.ashareapi.com/v1"
H = {}          # 免费端点无需 Key；付费端点加 {"Authorization": "Bearer ct-你的Key"}

def get(path, **params):
    r = requests.get(f"{BASE}/{path}", params=params, headers=H, timeout=30)
    if r.status_code == 429:                  # 超频：见第五节
        raise RuntimeError("rate limited")
    r.raise_for_status()
    body = r.json()
    if not body.get("ok"):
        raise RuntimeError(f"upstream failed (not counted): {body}")
    return body["data"]

# 历史 K 线（免费）——等价 stock_zh_a_hist（无区间参数，取最近 N 根，回来自己按日期过滤）
bars = get("kline", code="sh600667", period="day", count=30)
for r in bars:
    print(r["date"], r["last"], r["volume"])   # 原「收盘」→ last

# 实时行情（免费）——等价 stock_zh_a_spot_em 的单只版本
q = get("quote", code="sh600667")
print(q[0]["last"], q[0]["turnover"])          # 最新价 / 换手率

import time, requests

BASE = "https://api.ashareapi.com/v1"
H = {}

def get_with_retry(path, tries=3, **params):
    for i in range(tries):
        r = requests.get(f"{BASE}/{path}", params=params, headers=H, timeout=30)
        if r.status_code == 429:              # 超频
            time.sleep(2 ** i)                # 退避重试（别死循环打）
            continue
        r.raise_for_status()
        body = r.json()
        if not body.get("ok"):                # 上游失败 → 不扣次数，可重试
            time.sleep(1)
            continue
        return body["data"]
    raise RuntimeError(f"{path}: failed after {tries} tries")