Compare commits
2
Commits
linux-web
...
ab00919059
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ab00919059 | ||
|
|
30ead2806d |
@@ -168,8 +168,8 @@ def emit(kind, payload):
|
|||||||
def save_lhb_today(conn):
|
def save_lhb_today(conn):
|
||||||
"""收盘后采集当日龙虎榜"""
|
"""收盘后采集当日龙虎榜"""
|
||||||
try:
|
try:
|
||||||
from src.fetcher.lhb_fetcher import fetch_lhb # 项目内已有实现
|
from src.fetcher.lhb_fetcher import fetch_lhb_date # 项目内已有实现
|
||||||
df = fetch_lhb()
|
df = fetch_lhb_date(datetime.now().strftime('%Y-%m-%d'))
|
||||||
if df is not None and not df.empty:
|
if df is not None and not df.empty:
|
||||||
from src.storage.db import upsert_rows
|
from src.storage.db import upsert_rows
|
||||||
upsert_rows(df, 'lhb_daily', conflict_cols=['trade_date', 'ts_code', 'reason'])
|
upsert_rows(df, 'lhb_daily', conflict_cols=['trade_date', 'ts_code', 'reason'])
|
||||||
|
|||||||
Reference in New Issue
Block a user