Django中如何使用django-celery完成异步任务-创新互联

这期内容当中小编将会给大家带来有关Django中如何使用django-celery完成异步任务 ，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

Django中如何使用django-celery完成异步任务 

安装Celery

我们可以使用pip在vietualenv中安装:

 pip install django-celery  celery

django settings设置

1. import djcelery
   

3. djcelery.setup_loader()
   

4. BROKER_URL = 'redis://127.0.0.1:6379/2'   ---使用redis当消息队列

注册

1. INSTALLED_APPS = [
   

2.     'django.contrib.admin',
   

3.     'django.contrib.auth',
   

4.     'django.contrib.contenttypes',
   

5.     'django.contrib.sessions',
   

6.     'django.contrib.messages',
   

7.     'django.contrib.staticfiles',
   

8.     'devops',
   

9.     'apps',
   

10.     'common',
    

11.     'djcelery',

12. ]

在apps下创建一个task.py文件

1. from celery import task
   

3. @task
   

4. def add(x, y):
   

5.     return x + y

  @task

 def pp():

 return 'ffffffffffffffffffffff'

返回settings将其导入进去

1. import djcelery

2. djcelery.setup_loader()
   

3. BROKER_URL = 'redis://127.0.0.1:6379/2'
   

4. CELERY_IMPORTS = ('apps.task')

随意选个views中的方法调用改task测试下

1. #项目列表
   

2. def project_list(request):
   

3.     admin = Admin.objects.get(id=get_current_admin_id(request))
   

4.     pt=admin.projects.all().order_by('-id')
   

5.    

6.     from apps import task
   

7.     tt=task.add.delay(2,2)
   

8.     print 'vvvvvvvvvvvvvvvvvvvv',tt              -----访问该功能时调用task的add方法

10.     page_objects = pages(pt, request, 5) ##分页
    

11.     return render_to_response('project/project_list.html',locals())

安装启动redis：略

启动runserver 与 celery

1. python manage.py runserver
   

2. python manage.py celery worker --loglevel=info

访问对应的页面看日志

1. [2017-11-10 14:55:17,016: INFO/MainProcess] Task apps.task.add[9bafe6d2-8411-4f5f-8eed-10444da0ae3a] succeeded in 0.00280212797225s: 4   --可以看到worker日志，返回结果

上述就是小编为大家分享的Django中如何使用django-celery完成异步任务 了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联-成都网站建设公司行业资讯频道。