23 lines
674 B
Python
23 lines
674 B
Python
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 |