1.創建celery文件夾
2.新建main.py和config.py文件
3.在main.py設置celery配置文件:如下
from celery import Celery
import os
導入應用設置文件(django)
if not os.getenv('DJANGO_SETTINGS_MODULE'):
os.environ['DJANGO_SETTINGS_MODULE'] = '配置文件名'
實例化文件
app = Celery('隨便起名字')
導入celery配置文件
app.config_from_object('config配置文件')
導入要執行的任務文件夾,會自動在文件下尋找tasks.py文件,並且執行文件里面的裝飾器@app.tasks(name='函數名')裝飾的函數.
app.autodiscover_tasks('要執行的任務文件夾')
啟動方法:
celery -A celery_tasks.main worker -l info 可以查看信息