mirror of
https://github.com/fastapiadmin/FastapiAdmin.git
synced 2026-09-20 20:39:55 +00:00
zhangtao
b05c9b035f
- 在 README 中添加了 Celery 任务管理的说明 - 在系统菜单中添加了任务管理相关菜单项 - 添加了任务管理的路由和权限 - 引入了 croniter 库用于处理 cron 表达式
25 lines
770 B
Python
25 lines
770 B
Python
# -*- coding: utf-8 -*-
|
|
|
|
from celery import Celery
|
|
|
|
|
|
from app.config.setting import settings
|
|
|
|
|
|
celery_app = Celery(
|
|
'task_manager', # 任务名称
|
|
broker=f"redis://:{settings.REDIS_PASSWORD}@{settings.REDIS_HOST}:{settings.REDIS_PORT}/{settings.REDIS_DB_NAME}", # broker消息中间件，
|
|
backend=f"redis://:{settings.REDIS_PASSWORD}@{settings.REDIS_HOST}:{settings.REDIS_PORT}/{settings.REDIS_DB_NAME}",
|
|
include=['app.core.tasks'] # tasks.py文件的引入
|
|
)
|
|
|
|
celery_app.conf.update(
|
|
timezone='Asia/Shanghai',
|
|
enable_utc=False,
|
|
broker_connection_retry_on_startup = True # 设置启动时重试 broker 连接
|
|
)
|
|
|
|
# 启动celery
|
|
# celery -A celery_app.celery_app worker --loglevel=info
|
|
# celery -A celery_app.celery_app beat --loglevel=info
|