feat: daily_kline sz分批(sz_a 0开头1349只/sz_b 3开头831只,各<500s安全)——参考news_collector分批模式,消除sz单批2180只超时(961s>600s)

2026-08-14 02:54:42 +08:00
parent b227156d6c
commit 4997941b53
1 changed files with 7 additions and 1 deletions
@@ -50,8 +50,14 @@ def get_codes(conn, prefix):
    if prefix == "sh":
        # 6/9/5 开头 → 上海（fetch_tx_klines 自动加 sh 前缀）
        return sorted([c for c in codes if c[0] in ("5", "6", "9")])
+    elif prefix == "sz_a":
+        # 深圳前半批（0 开头）——2026-08-13 分批：sz 2180只超时，分 sz_a/sz_b
+        return sorted([c for c in codes if c[0] == "0"])
+    elif prefix == "sz_b":
+        # 深圳后半批（3 开头）
+        return sorted([c for c in codes if c[0] == "3"])
    else:
-        # 0/3 开头 → 深圳
+        # 0/3 开头 → 深圳（全部，兼容旧调用）
        return sorted([c for c in codes if c[0] in ("0", "3")])