希望在下一版中，能用这个小芹菜，来实现异步的多任务并行哈。
安装REDIS之类的不表，只说在DJANGO当中要注意配置的事项。
0，安装插件
yum install redis-server pip install celery pip install celery-with-redis pip install django-celery
1,settings.py当中的配置：
import djcelery djcelery.setup_loader() BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' CELERY_ACCEPT_CONTENT = ['json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json'
2，celery.py当中的配置(实际应用时，注意PROJECT和APP的变通配置)
from __future__ import absolute_import import os from celery import Celery from django.conf import settings os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celerytest.settings') app = Celery('celerytest') app.config_from_object('django.conf:settings') app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) def debug_task(self): print('Request: {0!r}'.format(self.request))
3,__init__.py当中的配置
from __future__ import absolute_import from .celery import app as celery_app
4，tasks.py当中的配置
from celerytest import celery_app from celery import shared_task from time import sleep @celery_app.task() def UploadTask(message): UploadTask.update_state(state='PROGRESS', meta={'progress': 0}) sleep(30) UploadTask.update_state(state='PROGRESS', meta={'progress': 30}) sleep(30) return message def get_task_status(task_id): task = UploadTask.AsyncResult(task_id) status = task.state progress = 0 if status == u'SUCCESS': progress = 100 elif status == u'FAILURE': progress = 0 elif status == 'PROGRESS': progress = task.info['progress'] return {'status': status, 'progress': progress} @celery_app.task def add(x, y): return x + y def mul(x, y): return x * y
5，测试代码
>>> from app.tasks import * >>> t = UploadTask.delay("heel") >>> get_task_status(t.id) {'status': u'PROGRESS', 'progress': 0} >>> get_task_status(t.id) {'status': u'PROGRESS', 'progress': 0} >>> get_task_status(t.id) {'status': u'PROGRESS', 'progress': 30} >>> get_task_status(t.id) {'status': u'PROGRESS', 'progress': 30} >>> get_task_status(t.id) {'status': u'SUCCESS', 'progress': 100} >>> add.delay(3245, 35) <AsyncResult: 6b45b2d6-2343-4d42-9810-e72d6c936a01>
6，启动worker（同样注意运行时的帐号，运行时当前目录，PROJ的名称及参数，在后期或是生产环境时，DAEMON的配置）
celery worker -A celerytest -l info
7，输出截图
