Celery配置和启动

1. task导入

from celery import task

2. conf配置

default.py中的配置项：CELERY_IMPORTS

3. 启动命令

启动worker：python manage.py celery worker --settings=setting --loglevel=info

启动celerybeat:python manage.py celerybeat --settings=settings

4. 任务执行

立即执行：xxx.delay(arg1,arg2)

定时执行：xxx.apply_async(args=[arg1, arg2],eta=start_time)