import logging from app.core.scheduler import scheduler from app.tasks.daily_tasks import register_daily_tasks logger = logging.getLogger(__name__) def init_scheduler(): """初始化并启动任务调度器""" try: # 注册所有定时任务 register_daily_tasks() # 这里可以添加其他类型的定时任务注册 # register_weekly_tasks() # register_monthly_tasks() # 启动调度器 scheduler.start() logger.info("任务调度器初始化完成并已启动") except Exception as e: logger.error(f"任务调度器初始化失败: {str(e)}") raise