From e2f02ad023ae8a66909986752f4d3e8c9b211a1a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=9F=A5=E5=BE=AE?= Date: Fri, 10 Jul 2026 14:06:20 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=B5=84=E9=87=91=E6=B5=81=E9=87=87?= =?UTF-8?q?=E9=9B=86=E5=99=A8=E6=AD=A3=E5=B8=B8=E8=BF=90=E8=A1=8C(?= =?UTF-8?q?=E4=BF=AEimport+=E7=A7=91=E5=88=9B=E6=9D=BFnull=E5=A4=84?= =?UTF-8?q?=E7=90=86)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- scripts/capital_flow_collector.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/scripts/capital_flow_collector.py b/scripts/capital_flow_collector.py index adac6e51..22477485 100644 --- a/scripts/capital_flow_collector.py +++ b/scripts/capital_flow_collector.py @@ -11,7 +11,7 @@ from datetime import datetime from urllib.request import urlopen, Request from concurrent.futures import ThreadPoolExecutor, as_completed from threading import Semaphore -from mofin_db import get_conn, write_capital_flow_cache, query_holdings, query_holdings_db, query_watchlist +from mofin_db import get_conn, write_capital_flow_cache DATA_DIR = "/home/hmo/web-dashboard/data" CACHE_PATH = f"{DATA_DIR}/capital_flow_cache.json" @@ -53,7 +53,9 @@ def fetch_flow(code, days=5): data = _rate_limited_request(url) if not data: return None - klines = data.get("data", {}).get("klines", []) + klines = data.get("data") or {} + if isinstance(klines, dict): + klines = klines.get("klines", []) if not klines: return None result = []