| 1234567891011121314151617181920212223242526272829303132 |
- import logging
- from app.core.dependency import ServerContainer
- logger = logging.getLogger(__name__)
- class AppContext:
- def __init__(self, container: ServerContainer):
- self.container = container
- async def start_up(self):
- logger.info("初始化数据库连接池")
- mysql = self.container.mysql_manager()
- await mysql.init_pools()
- logger.info("Mysql pools init successfully")
- logger.info("初始化日志服务")
- log_service = self.container.log_service()
- await log_service.start()
- logger.info("aliyun log service init successfully")
- async def shutdown(self):
- """这里只做资源关闭;日志与告警 flush 由 task_app.py 统一编排"""
- logger.info("关闭数据库连接池")
- mysql = self.container.mysql_manager()
- await mysql.close_pools()
- logger.info("应用资源已释放")
- __all__ = [
- "AppContext",
- ]
|