from __future__ import absolute_import, unicode_literalsimport osfrom celery import Celery, platforms# set the default Django settings module for the 'celery' program.os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'website.settings')app = Celery('website')# Using a string here means the worker don't have to serialize# the configuration object to child processes.# - namespace='CELERY' means all celery-related configuration keys# should have a `CELERY_` prefix.app.config_from_object('django.conf:settings', namespace='CELERY')# Load task modules from all registered Django app configs.app.autodiscover_tasks()# 允许root 用户运行celeryplatforms.C_FORCE_ROOT = True@app.task(bind=True)def debug_task(self): print('Request: {0!r}'.format(self.request))
from __future__ import absolute_import# This will make sure the app is always imported when# Django starts so that shared_task will use this app.from .celery import app as celery_app__all__ = ['celery_app']
6.各应用创建tasks.py文件，这里为deploy/tasks.py
from __future__ import absolute_importfrom celery import shared_task@shared_taskdef add(x, y): return x + y
注意tasks.py必须建在各app的根目录下，且只能叫tasks.py，不能随意命名
7.views.py中引用使用这个tasks异步处理
from deploy.tasks import adddef post(request): result = add.delay(2, 3)
