django学习笔记7：django和celery实现异步

柔光的暖阳◎ 2022-09-22 14:53 199阅读 0赞

django和celery实现异步：

首先安装：

pip install celery

pip install django-celery

pip install django-kombu

修改mytest\\mytest\\settings.py

在开头添加：

import djcelery
    djcelery.setup_loader()
    BROKER_URL='django://'
    
    INSTALLED_APPS = [
                        ..........
                       'djcelery',
                       "kombu.transport.django",
    ]

最后创建Celery所需的数据表, 运行:

python manage.py migrate  
![Center][]

在mytest\\test1\\下添加tasks.py

#coding:utf-8
    import time
    from celery.task import task
    
    import django
    django.setup()
    
    @task
    def _do_kground_work(name):
        print name
        time.sleep(5)

wenidow下要添加：

import django

django.setup()

不然会报app未加载的错误

这里是创建一个任务，简单的打印字符串

修改mytest\\test1\\views.py

新增以下内容：

from .tasks import _do_kground_work
    
    def hello(request):
        _do_kground_work.delay('GreenPine')
        return HttpResponse('Hello, World!!!!!')

导入自定义的任务，延时执行任务，先出现 HttpResponse里的内容

修改mytest\\test1\\urls.py

添加：

url( r'^hello/$',test1\_views.hello,name='hello') ,

先到项目中启动django服务，python manage.py runserver 或者 masge.py runserver

再打开一个终端，进入项目，python manage.py celery worker --loglevel=info 或者 manage.py celery worker --loglevel=info

浏览器进入127.0.0.1:8000/hello/

浏览器显示：  
![Center 1][]  
浏览器没刷新一次，就会在 worker终端出现'GreenPine'字符串，但是页面始终是hello world!!!!  
![Center 2][]  
通过任务调度实现异步

django和celery再具体一点的实现：

修改 mytest\\test1\\tasks.py

#coding:utf-8
    import time
    from celery.task import task
    
    import django
    django.setup()
    
    @task
    def _do_kground_work(name):
        for u in range(10):
            time.sleep(1)
        print name
        time.sleep(5)

修改 mytest\\test1\\forms.py

新增以下内容：

class AddHello(forms.Form):
        t = forms.IntegerField()

修改mytest\\test1\\views.py

from .forms import AddForm,AddHello
    
    def to_hello(request):
        form = AddHello()
        return render(request,'to_hello.html',{'form':form})
    
    def hello(request):
        if request.method =='POST':
            form = AddHello(request.POST)
            if form.is_valid():
                t = form.cleaned_data['t']
                _do_kground_work.delay('GreenPine'+str(t))
                return render(request,'hello.html',{'t':t})

新增mytest\\test1\\templates\\to\_hello.html

<form  action={% url 'hello' %} method="post">
                {% csrf_token %}
                {
          { form}}
             <input type="submit" value="OK">
            </form>

新增mytest\\test1\\templates\\hello.html

<a href="{% url 'to_hello' %}">to_hello</a>
    {
          {t}} hello world

修改urls.py

url( r'^to\_hello/$',test1\_views.to\_hello,name='to\_hello'),

先到项目中启动django服务，python manage.py runserver 或者 masge.py runserver

再打开一个终端，进入项目，python manage.py celery worker --loglevel=info 或者 manage.py celery worker --loglevel=info

浏览器进入127.0.0.1:8000/to\_hello/

浏览器显示：

![Center 3][]   
输入数字后跳转到hello页面  
![Center 4][]  
worker终端显示：  
![Center 5][]

数据都传过来了，再点击to\_hello回到to\_hello页面，再输入数字，就这样一直循环动作看着worker终会发现celery的任务是排队的，等前一个完成后再进行下一个

这里可以看出来 celery和django实现异步其实是通过两个服务完成

django将一个需要长时间等待才能完成的任务扔给了 celery的服务，然后自己继续执行，这样在页面上就感觉是异步完成

而 celery收到任务以后还是扔到一个列队里，每个任务排队一个一个的执行

不过我试了一下很频繁的多次扔任务会报错，然后 celery得服务会停掉，难道是我手速太快了？？？

[Center]: /images/20220721/235ae6e488da49cb9a80fd30859be9a2.png
[Center 1]: /images/20220721/04052ba9ece04d3cab1bce919a0d1f1b.png
[Center 2]: /images/20220721/3b89a3c78e3c42a9b6feba35ff6afd9f.png
[Center 3]: /images/20220721/7f30f629770c42538e715278e743de0b.png
[Center 4]: /images/20220721/fad7f79ee21844188902dfdb86599c0a.png
[Center 5]: /images/20220721/0ba6fac9768a45d693ca6dfcbcf9ee66.png