diff --git a/scripts/data_platform/verify_akshare_e2e.py b/scripts/data_platform/verify_akshare_e2e.py index f125670..1242018 100644 --- a/scripts/data_platform/verify_akshare_e2e.py +++ b/scripts/data_platform/verify_akshare_e2e.py @@ -14,10 +14,13 @@ sys.stdout.reconfigure(line_buffering=True) BASE = Path(r"C:\sanguo_vnpy_v2\data") ok, warn = [], [] -# 1. static/ 各表文件数 + 最新 mtime -print("===== static/ 各表 =====") +# 1. static/ 各表文件数 + 最新 mtime (akshare_static_download 全部类型都落 data/static//) +# per-stock(估值/三表/摘要/北向/股本/十大股东) + per-date(龙虎榜/大宗/两融/解禁) + per-period(预告/快报) +print("===== static/ 各表 (akshare 全类型) =====") for sub in ["valuation", "financial_abstract", "balance", "income", "cashflow", - "northbound", "share_capital", "top_holders"]: + "northbound", "share_capital", "top_holders", + "dragon_tiger", "block_trade", "margin_sse", "restricted", + "forecast", "express"]: d = BASE / "static" / sub if not d.exists(): warn.append(f"static/{sub} MISSING") @@ -33,20 +36,7 @@ for sub in ["valuation", "financial_abstract", "balance", "income", "cashflow", print(f" {sub}: {len(fs)} parquet, latest={latest}") ok.append(f"static/{sub}") -# 2. events/ per-date 类 -print("\n===== events/ per-date 类 =====") -for sub in ["dragon_tiger", "block_trade", "margin_sse", "restricted"]: - d = BASE / "events" / sub - if not d.exists(): - warn.append(f"events/{sub} MISSING(ak-events 未跑或当日无数据)") - print(f" {sub}: MISSING") - continue - fs = list(d.glob("*.parquet")) - print(f" {sub}: {len(fs)} parquet") - if fs: - ok.append(f"events/{sub}") - -# 3. constituent_unified + _old +# 2. constituent_unified + _old (akshare 全类型已在 section 1 的 static/ 检查覆盖) print("\n===== constituent_unified + _old =====") c = sqlite3.connect(str(BASE / "quant_trading.db"), timeout=60) try: