From 42659b92e9973f7dccc1fbcdcb8edb5c65246066 Mon Sep 17 00:00:00 2001 From: zlt Date: Fri, 24 Jul 2026 15:20:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=86=E5=8F=B2=E6=B7=B1=E5=BA=A6=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=8E=A2=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- run.py | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/run.py b/run.py index 5e153a7..4d6d293 100644 --- a/run.py +++ b/run.py @@ -40,17 +40,19 @@ def cmd_views(): print(f" ❌ {name}: {e!r}") fronts = [ - ("热度 heat(trade_date)", "heat", "SELECT MAX(trade_date) FROM stock_fund_heat_scores"), - ("一致预期 consensus(asof)", "pg", "SELECT MAX(asof_date) FROM v_factor_consensus"), - ("事件 events(disclosure)", "pg", "SELECT MAX(disclosure_date) FROM v_factor_events"), - ("传导 transmission(scan)", "pg", "SELECT MAX(scan_date) FROM v_factor_transmission"), - ("行情 gp_day_data(ts)", "price", "SELECT MAX(`timestamp`) FROM gp_day_data"), + ("热度 heat", "heat", "trade_date", "stock_fund_heat_scores"), + ("一致预期 consensus", "pg", "asof_date", "v_factor_consensus"), + ("事件 events", "pg", "disclosure_date", "v_factor_events"), + ("传导 transmission", "pg", "scan_date", "v_factor_transmission"), + ("行情 gp_day_data", "price", "`timestamp`", "gp_day_data"), ] - print("\n数据前沿（各源最新日期——build 的 --date 照此选，别选没数据的未来日）：") - for name, src, sql in fronts: + print("\n数据历史深度（min ~ max，distinct 天数——回填范围据此定）：") + for name, src, col, tbl in fronts: + sql = f"SELECT MIN({col}), MAX({col}), COUNT(DISTINCT {col}) FROM {tbl}" try: df = db.read_pg(sql) if src == "pg" else db.read_mysql(src, sql) - print(f" {name}: {df.iloc[0, 0]}") + lo, hi, n = df.iloc[0, 0], df.iloc[0, 1], df.iloc[0, 2] + print(f" {name}: {lo} ~ {hi} ({int(n)} 天)") except Exception as e: # noqa: BLE001 print(f" {name}: ❌ {e!r}")