Python中如何使用Django结合Celery异步运行周期任务

目前是 django 写了一个接口, 访问之后创建任务, 现在希望能创建这些任务之后, 任务每 5 分钟运行一次. 也就是能动态添加周期任务, 目前用了 djcelery 希望 django admin 也能管理, 但是现在利用官方的这种写法并不能生效:

def setup_periodic_tasks(sender, q, **kwargs):
    # Calls test('hello') every 10 seconds.
    sender.add_periodic_task(20.0, test.s(q), name='add every 10 min')

上边的的函数调不起来 test 函数 celery shell 中没有 beat 监听到的任何消息..


Python中如何使用Django结合Celery异步运行周期任务

7 回复

试试 django-celery-beat 这个库。


在Django里用Celery搞周期任务，直接上代码最实在。首先得装几个包：

pip install django celery django-celery-beat

然后配置你的settings.py：

# settings.py
INSTALLED_APPS = [
    # ...其他应用
    'django_celery_beat',
]

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'  # 用Redis做消息代理
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TIMEZONE = 'Asia/Shanghai'
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

在项目根目录创建celery.py：

# proj/celery.py
import os
from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
app = Celery('proj')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print(f'Request: {self.request!r}')

在__init__.py里导入：

# proj/__init__.py
from .celery import app as celery_app

__all__ = ('celery_app',)

现在创建个任务，比如在某个app的tasks.py里：

# yourapp/tasks.py
from celery import shared_task
from datetime import datetime

@shared_task
def my_periodic_task():
    print(f"周期任务执行于: {datetime.now()}")
    # 这里写你的业务逻辑
    return "任务完成"

最后通过Django Admin或者代码创建周期任务。在Admin里进到"Periodic tasks"添加新任务，选你的任务函数，设置cron表达式或间隔时间。

启动命令分两个终端：

# 终端1：启动worker
celery -A proj worker --loglevel=info

# 终端2：启动beat调度器
celery -A proj beat --loglevel=info

这样就齐活了，任务会按你设的时间自动执行。记得Redis得先跑起来。

总结：配置好Celery和beat，用装饰器定义任务，在Admin里设调度。

django-celery-beat 进行数据库迁移，可以在 admin 中管理任务

是的 用了这个库 可是就算用官方的写法, 也看不出来任何被调用的信息. 开不起来任务…

楼主提供的信息太少根本无法判断问题出在哪里了。
比如你的 celery 服务进程跑起来了么，broker 队列里面收到任务了没有之类的都不知道。
自己打几个断点跟踪一下，哪怕在关键点 print 一下信息也可以。

任务用 task 装饰器了吗？ celery, celery beat 都启动了么，可以看 celery 的 log。

谢各位 , 装了 djcelery 同时也装 django-celery-beat 之后手贱非要升级被 djcelery 降到 3.x 的原本 4.2 的 celery 版本, 没有认真读依赖关系.

回到顶部