Django中怎么使用Celery實現(xiàn)異步-創(chuàng)新互聯(lián)

本篇文章為大家展示了Django中怎么使用Celery實現(xiàn)異步，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

創(chuàng)新互聯(lián)建站成立與2013年，公司以網(wǎng)站制作、成都網(wǎng)站制作、系統(tǒng)開發(fā)、網(wǎng)絡推廣、文化傳媒、企業(yè)宣傳、平面廣告設計等為主要業(yè)務，適用行業(yè)近百種。服務企業(yè)客戶近千家，涉及國內(nèi)多個省份客戶。擁有多年網(wǎng)站建設開發(fā)經(jīng)驗。為企業(yè)提供專業(yè)的網(wǎng)站建設、創(chuàng)意設計、宣傳推廣等服務。通過專業(yè)的設計、獨特的風格，為不同客戶提供各種風格的特色服務。

apt-get install python3
pip3 install django

嗯，就是兩條命令的事兒。

再說celery的安裝：

pip3 install celery
pip3 install redis==2.10.6

目前奶牛所在的時間redis for python的版本是redis-3.0.1，為什么要用2.10.6呢？因為3.0.1壓根配置就無法運行?。。?/p>

繼續(xù)安裝redis server

apt-get install redis
service redis start

然后就可以按照celery的官方教程走了，放個URL：http://docs.celeryproject.org/en/latest/django/index.html

python3 manage.py startproject nenew
cd nenew
python3 manage.py startapp nenewapp
touch ./nenew/celery.py
touch ./nenewapp/tasks.py

然后增加nenew/nenew/celery.py內(nèi)容為

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'nenew.settings')

app = Celery('nenew')

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#  should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
  print('Request: {0!r}'.format(self.request))

增加nenew/nenew/__init__.py的內(nèi)容

from __future__ import absolute_import, unicode_literals

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

__all__ = ('celery_app',)

增加nenew/nenewtest/tasks.py的內(nèi)容

# Create your tasks here
from __future__ import absolute_import, unicode_literals
from celery import shared_task


@shared_task
def add(x, y):
  return x + y


@shared_task
def mul(x, y):
  return x * y


@shared_task
def xsum(numbers):
  return sum(numbers)

在nenew/nenew/settings.py中增加和修改

...

ALLOWED_HOSTS = ['*']
....

INSTALLED_APPS = [
...
  'nenewtest',
]

...

CELERY_BROKER_URL = 'redis://localhost:6379/1'
CELERY_RESULT_BACKEND = ‘redis://localhost:6379/0'

在nenew/nenewtest/views.py中增加或修改為

from django.shortcuts import render
from django.http import HttpResponse
from .tasks import add
# Create your views here.
def nenewtest(request):
  result = add.delay('2','2')
  result.ready()
  return HttpResponse('nenew Django Celery worker run !')

最后把views添加到nenew/nenew/urls.py中

from django.contrib import admin
from django.urls import path
from nenewtest import views

urlpatterns = [
  path('admin/', admin.site.urls),
  path('test/', views.nenewtest),
]

然后在項目目錄nenew執(zhí)行

celery -A nenew worker -l info

這時候worker啟動正常會顯示：

-------------- <a href="/cdn-cgi/l/email-protection" rel="external nofollow" data-cfemail="2c4f4940495e556c424942495b">[email protected]</a> v4.2.1 (windowlicker)
---- **** -----
--- * *** * -- Linux-4.15.0-39-generic-x86_64-with-Ubuntu-18.04-bionic 2018-11-23 17:31:25
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         nenew:0x7fdc5a155cc0
- ** ---------- .> transport:   redis://localhost:6379/1
- ** ---------- .> results:     redis://localhost:6379/0
- *** --- * --- .> concurrency: 1 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
                .> celery           exchange=celery(direct) key=celery

這樣類似的信息，然后我們啟動項目，這里需要新開一個shell：

python3 manage.py runserver 0:80

這樣我們就可以通過80端口直接訪問我們的web了。地址是http://locahost/test

當我們這里訪問正常后，在worker界面會有

[2018-11-23 18:09:19,469: INFO/MainProcess] Received task: nenewtest.tasks.add[35faa0fe-dd48-4f8d-9559-516556a93a40]
[2018-11-23 18:09:19,470: INFO/ForkPoolWorker-1] Task nenewtest.tasks.add[35faa0fe-dd48-4f8d-9559-516556a93a40] succeeded in 0.00031037399821798317s: '22'

如下語句表示執(zhí)行成功，這樣子就表示通過Django的網(wǎng)頁我們對celery任務的異步執(zhí)行成功。

當然，按照我的方法是可以一步成功的，因為奶牛已經(jīng)踩了一整天的坑了，被一個錯誤郁悶得不要不要的。

AttributeError: 'float' object has no attribute 'items'

就是這個錯誤，查遍國內(nèi)的所有網(wǎng)站都沒有結(jié)果，然后就去bing的國際版查，然后發(fā)現(xiàn)果然是有bug在啊，奶牛這一天浪費得可真是夠了。

這是celery的一個issue，在地址https://github.com/celery/celery/issues/5175 ，issue里面提及在2018/11/22日 it's fixed in kombu and celery master。問題的根源是celery對redis3的支持不好，補救方法是

Solution: Roll back redis with pip: pip install redis==2.10.6

然后在commit里面找到是對requirements/extras/redis.txt文件進行版本限定。

-redis>=2.10.5
+redis>=2.10.5,<3

上述內(nèi)容就是Django中怎么使用Celery實現(xiàn)異步，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

當前標題：Django中怎么使用Celery實現(xiàn)異步-創(chuàng)新互聯(lián)
網(wǎng)站URL：http://www.muchs.cn/article48/dpcpep.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供建站公司、手機網(wǎng)站建設、商城網(wǎng)站、外貿(mào)網(wǎng)站建設、網(wǎng)站制作、外貿(mào)建站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容