fanhuadesenlinnn/daily_stock_analysis
1
0
Fork 0
mirror of https://github.com/ZhuLinsen/daily_stock_analysis synced 2026-09-20 10:53:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update market_analyzer.py

Browse Source 
北向资金已于2024年8月19日之后不再提供数据，注释掉相关代码
This commit is contained in:
hhaishen
2026-01-14 23:43:54 +08:00
committed by GitHub
parent ae2e21f21d
commit 6f510e377f
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
market_analyzer.py
View File

@@ -128,7 +128,7 @@ class MarketAnalyzer:
self._get_sector_rankings(overview)
# 4. 获取北向资金（可选）
self._get_north_flow(overview)
# self._get_north_flow(overview)
return overview
@@ -245,26 +245,26 @@ class MarketAnalyzer:
except Exception as e:
logger.error(f"[大盘] 获取板块涨跌榜失败: {e}")
def _get_north_flow(self, overview: MarketOverview):
"""获取北向资金流入"""
try:
logger.info("[大盘] 获取北向资金...")
# def _get_north_flow(self, overview: MarketOverview):
# """获取北向资金流入"""
# try:
# logger.info("[大盘] 获取北向资金...")
# 获取北向资金数据
df = ak.stock_hsgt_north_net_flow_in_em(symbol="北上")
# # 获取北向资金数据
# df = ak.stock_hsgt_north_net_flow_in_em(symbol="北上")
if df is not None and not df.empty:
# 取最新一条数据
latest = df.iloc[-1]
if '当日净流入' in df.columns:
overview.north_flow = float(latest['当日净流入']) / 1e8 # 转为亿元
elif '净流入' in df.columns:
overview.north_flow = float(latest['净流入']) / 1e8
# if df is not None and not df.empty:
# # 取最新一条数据
# latest = df.iloc[-1]
# if '当日净流入' in df.columns:
# overview.north_flow = float(latest['当日净流入']) / 1e8 # 转为亿元
# elif '净流入' in df.columns:
# overview.north_flow = float(latest['净流入']) / 1e8
logger.info(f"[大盘] 北向资金净流入: {overview.north_flow:.2f}亿")
# logger.info(f"[大盘] 北向资金净流入: {overview.north_flow:.2f}亿")
except Exception as e:
logger.warning(f"[大盘] 获取北向资金失败: {e}")
# except Exception as e:
# logger.warning(f"[大盘] 获取北向资金失败: {e}")
def search_market_news(self) -> List[Dict]:
"""