Django 异步化库celery

时间：2019-03-19 12:31:32 阅读：142 评论：0 收藏：0 [点我收藏+]

标签：bind view def sel 怎么 over 图片 settings ports

首先要了解Django其实是个同步框架，那么多个用户发送请求时就会发生排队的情况上一个用户的请求完成后在进行下一个，这样会对影响用户体验，所有就要用到异步方法来解决。

首先我们要安装celery库

pip install celery celery的基础库

pip install celery-with-redis celery对redis的库

pip install django-celery celery对django的库

安装完成后要在settings.py内进行设置

#配置celery
import djcelery
djcelery.setup_loader()
BROKER_URL = ‘redis://127.0.0.1:6379‘
CELERY_IMPORTS = (‘mymac.tasks‘)

还要在同级目录下建立一个 celert.py文件

#导包
import os
import django
from celery import Celery
from django.conf import settings 
os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘mymac.settings‘)
django.setup()
app = Celery(‘mymac‘)
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))

然后建立一个py文件创建celert异步方法

#导包
import time
#导入异步任务
from celery.task import task

#task使用装饰器用法
@task
def say(x,y):
    #稍后用于方便查看异步
    time.sleep(5)
    return x+y

在视图方法导入写好的异步方法，配置好相应路由访问即可

from django.shortcuts import render,redirect
#导包
from django.http import HttpResponse,HttpResponseRedirect
#导入类视图 
from django.views import View
#导入异步方法
from mymac.tasks import sayl

def celery_test(request):
    #用delay传参
    print(say.delay(‘123‘,‘123‘))
    return HttpResponse(‘异步测试‘)