From da407f4f1194b5d065ed006ade114a5a56a0381d Mon Sep 17 00:00:00 2001 From: cfdaily Date: Wed, 6 May 2026 09:56:32 +0800 Subject: [PATCH] auto-sync: 2026-05-06 09:56:32 --- data_platform/daily_all_update.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/data_platform/daily_all_update.py b/data_platform/daily_all_update.py index 045e9d71..491c5be2 100644 --- a/data_platform/daily_all_update.py +++ b/data_platform/daily_all_update.py @@ -821,6 +821,12 @@ def run_15min_update(codes: List[str], local_conn: sqlite3.Connection) -> dict: existing = pd.read_parquet(parquet_path) existing["day"] = existing["day"].astype(str) + # 统一类型：旧数据volume/amount可能是str，新数据是float + for col in ["volume", "amount", "open", "high", "low", "close"]: + if col in existing.columns: + existing[col] = pd.to_numeric(existing[col], errors="coerce").fillna(0) + if col in df_increment.columns: + df_increment[col] = pd.to_numeric(df_increment[col], errors="coerce").fillna(0) combined = pd.concat([existing, df_increment], ignore_index=True) combined = combined.sort_values("day").reset_index(drop=True) new_rows = len(df_increment)