网站优化

网站优化

Products

当前位置:首页 > 网站优化 >

“掌握Django Celery Beat,轻松实现高效定时任务!”

GG网络技术分享 2025-11-14 01:59 2


INSTALLED_APPS =

接下来 你需要在你的Django项目的根目录下创建一个名为celery.py的文件,并添加以下内容:

python

import os from celery import Celery

os.environ.setdefault

app = Celery

app.configfromobject

app.autodiscover_tasks

然后在settings.py文件中添加以下配置:

CELERYBROKERURL = 'redis://localhost:6379/0' CELERYRESULTBACKEND = 'redis://localhost:6379/0' CELERYBEATSCHEDULER = 'djangocelerybeat.schedulers.DatabaseScheduler'

眼下你Yi经配置优良了Celery和Django Celery Beat,Neng开头创建定时任务了。创建一个名为tasks.py的文件在你的Django应用目录下 并添加以下内容:

from celery import shared_task

@sharedtask def myperiodic_task: # 你的定时任务逻辑 pass

在你的celery.py中,你Neng定义任务的调度计划:

app.conf.beatschedule = { 'myperiodictask': { 'task': 'myapp.tasks.myperiodictask', 'schedule': timedelta, # 每分钟施行一次 'options': { 'queue': 'myqueue', }, }, }

再说说确保你的Celery worker和beat服务正在运行:

bash celery -A your_project worker --loglevel=info celery -A your_project beat --loglevel=info

这样,你就配置优良了Django项目中的Celery Beat定时任务。

标签:

提交需求或反馈

Demand feedback