aaron/stock-ai-agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
aaron 2026-02-24 15:44:56 +08:00
parent 926296fc57
commit 265e9d39c8
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
backend/app/main.py
View File

@ -391,18 +391,30 @@ async def lifespan(app: FastAPI):
except Exception as e: except Exception as e:
logger.error(f"加密货币智能体启动失败: {e}") logger.error(f"加密货币智能体启动失败: {e}")
# 启动美股智能体 # 启动股票智能体（美股 + 港股）
if getattr(settings, 'stock_symbols', '') and settings.stock_symbols.strip(): us_symbols = getattr(settings, 'stock_symbols_us', '') or ''
hk_symbols = getattr(settings, 'stock_symbols_hk', '') or ''
if (us_symbols.strip() or hk_symbols.strip()):
try: try:
from app.stock_agent.stock_agent import get_stock_agent from app.stock_agent.stock_agent import get_stock_agent
stock_agent = get_stock_agent() stock_agent = get_stock_agent()
_stock_agent_task = asyncio.create_task(stock_agent.start()) _stock_agent_task = asyncio.create_task(stock_agent.start())
# 设置智能体实例到 API 模块 # 设置智能体实例到 API 模块
stocks.set_stock_agent(stock_agent) stocks.set_stock_agent(stock_agent)
logger.info(f"美股智能体已启动，监控: {settings.stock_symbols}")
symbols_list = []
if us_symbols:
symbols_list.append(f"美股({len(us_symbols.split(','))}只)")
if hk_symbols:
symbols_list.append(f"港股({len(hk_symbols.split(','))}只)")
logger.info(f"股票智能体已启动，监控: {', '.join(symbols_list)}")
except Exception as e: except Exception as e:
logger.error(f"美股智能体启动失败: {e}") logger.error(f"股票智能体启动失败: {e}")
logger.error(f"提示: 请确保已安装 yfinance (pip install yfinance)") logger.error(f"提示: 请确保已安装 yfinance (pip install yfinance)")
else:
logger.info("股票智能体未启动（未配置股票代码）")
# 显示系统状态摘要 # 显示系统状态摘要
await _print_system_status() await _print_system_status()