diff --git a/deploy/profile-scripts/daily_kline_collector.py b/deploy/profile-scripts/daily_kline_collector.py index 8f3eff3b..72348b89 100644 --- a/deploy/profile-scripts/daily_kline_collector.py +++ b/deploy/profile-scripts/daily_kline_collector.py @@ -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")])