feat(stock-sdk): 取数入口补充 INFO 日志, 便于确认切换后实际走 stock-sdk

This commit is contained in:
shy3130
2026-07-07 13:07:59 +08:00
parent bfc4168612
commit 03e99bd05f
+3
View File
@@ -67,6 +67,7 @@ class StockSDKProvider:
) -> pl.DataFrame:
if not symbols:
return pl.DataFrame()
logger.info("stock-sdk daily 拉取开始(%d symbols)", len(symbols))
frames: list[pl.DataFrame] = []
chunks = chunked(symbols, _BATCH)
for i, chunk in enumerate(chunks):
@@ -141,6 +142,7 @@ class StockSDKProvider:
if not symbols:
return pl.DataFrame()
period = "".join(ch for ch in str(freq) if ch.isdigit()) or "5"
logger.info("stock-sdk minute 拉取开始(%d symbols, period=%s)", len(symbols), period)
frames: list[pl.DataFrame] = []
chunks = chunked(symbols, _BATCH)
for i, chunk in enumerate(chunks):
@@ -193,6 +195,7 @@ class StockSDKProvider:
# ---- realtime (全市场快照) ----
def get_realtime(self) -> list[dict]:
logger.info("stock-sdk realtime 拉取开始(全市场快照)")
try:
result = bridge.run_job({"op": "realtime"}, timeout=120)
except bridge.StockSDKBridgeError as e: