|
|
|
@ -57,6 +57,13 @@ async def lifespan(app: FastAPI):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
logger.error("存储模式: SQLite (Redis 和 MySQL 均不可用)")
|
|
|
|
logger.error("存储模式: SQLite (Redis 和 MySQL 均不可用)")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if mysql_ok:
|
|
|
|
|
|
|
|
from app.mysql_database import mysql_engine
|
|
|
|
|
|
|
|
from app.models import Base as MarketBase, MarketData, SymbolTimestamp
|
|
|
|
|
|
|
|
# 在 MySQL 中创建行情相关表
|
|
|
|
|
|
|
|
MarketBase.metadata.create_all(bind=mysql_engine, tables=[MarketData.__table__, SymbolTimestamp.__table__])
|
|
|
|
|
|
|
|
logger.info("MySQL 表结构初始化完成")
|
|
|
|
|
|
|
|
|
|
|
|
# 创建默认管理员账户
|
|
|
|
# 创建默认管理员账户
|
|
|
|
from app.database import SessionLocal
|
|
|
|
from app.database import SessionLocal
|
|
|
|
from app import auth_service
|
|
|
|
from app import auth_service
|
|
|
|
|