django celery redis简单测试-白红宇

希望在下一版中，能用这个小芹菜，来实现异步的多任务并行哈。

安装REDIS之类的不表，只说在DJANGO当中要注意配置的事项。

0，安装插件

yum install redis-serverpip install celerypip install celery-with-redispip install django-celery

1,settings.py当中的配置：

import djcelerydjcelery.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_importimport osfrom celery import Celeryfrom django.conf import settingsos.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_importfrom .celery import app as celery_app

4，tasks.py当中的配置

from celerytest import celery_appfrom celery import shared_taskfrom 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 messagedef 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.taskdef add(x, y):    return x + ydef 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)

6，启动worker（同样注意运行时的帐号，运行时当前目录，PROJ的名称及参数，在后期或是生产环境时，DAEMON的配置）

celery worker -A celerytest -l info

7，输出截图