fix: 龙虎榜采集函数名对齐(fetch_lhb_date)
This commit is contained in:
@@ -168,8 +168,8 @@ def emit(kind, payload):
|
||||
def save_lhb_today(conn):
|
||||
"""收盘后采集当日龙虎榜"""
|
||||
try:
|
||||
from src.fetcher.lhb_fetcher import fetch_lhb # 项目内已有实现
|
||||
df = fetch_lhb()
|
||||
from src.fetcher.lhb_fetcher import fetch_lhb_date # 项目内已有实现
|
||||
df = fetch_lhb_date(datetime.now().strftime('%Y-%m-%d'))
|
||||
if df is not None and not df.empty:
|
||||
from src.storage.db import upsert_rows
|
||||
upsert_rows(df, 'lhb_daily', conflict_cols=['trade_date', 'ts_code', 'reason'])
|
||||
|
||||
Reference in New Issue
Block a user