From a3b1934ddfbbfbc78dfee8717ee4660c5d7fe152 Mon Sep 17 00:00:00 2001 From: cfdaily Date: Tue, 5 May 2026 09:02:54 +0800 Subject: [PATCH] auto-sync: 2026-05-05 09:02:54 --- data_platform/daily_all_update.py | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) diff --git a/data_platform/daily_all_update.py b/data_platform/daily_all_update.py index 667f613c..e06c05ec 100644 --- a/data_platform/daily_all_update.py +++ b/data_platform/daily_all_update.py @@ -673,7 +673,7 @@ def run_15min_update(codes: List[str]) -> dict: break if i > 0: - time.sleep(REQUEST_INTERVAL) + time.sleep(REQUEST_INTERVAL_SINA) try: status, new_rows, db_values = update_15min_parquet(code) @@ -735,6 +735,21 @@ def _write_vnpy_db(values: list, label: str): conn = sqlite3.connect(local_tmp, timeout=30) c = conn.cursor() c.execute("PRAGMA journal_mode=WAL") + c.execute("""CREATE TABLE IF NOT EXISTS dbbardata ( + id INTEGER PRIMARY KEY AUTOINCREMENT, + symbol TEXT NOT NULL, + exchange TEXT NOT NULL, + datetime TEXT NOT NULL, + interval TEXT NOT NULL, + volume REAL DEFAULT 0, + turnover REAL DEFAULT 0, + open_interest REAL DEFAULT 0, + open_price REAL, + high_price REAL, + low_price REAL, + close_price REAL, + UNIQUE(symbol, exchange, datetime, interval) + )""") c.executemany( """INSERT OR REPLACE INTO dbbardata (symbol,exchange,datetime,interval,volume,turnover,open_interest,