django之如何使用celery把耗時程序放到celery里面執(zhí)行

這篇文章主要為大家展示了“django之如何使用celery把耗時程序放到celery里面執(zhí)行”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“django之如何使用celery把耗時程序放到celery里面執(zhí)行”這篇文章吧。

1　在虛擬環(huán)境創(chuàng)建項目test和應用booktest（過程省略），然后安裝所需的包

pip install celery==3.1.25
pip install celery-with-redis==3.0
pip install django-redis==3.1.17

2　配置settings，

# 數(shù)據(jù)庫使用mysql
DATABASES = {
  'default': ｛
    'ENGINE':'django.db.backends.mysql',
    'NAME':'test',
    'USER':'root',
    'PASSWORD':'mysql',
    'HOST':'localhost',
    'PORT':3306,
  }
}

# 注冊djcelery應用
INSTALLED_APPS = (
  ...
  'djcelery',
)

# celery配置

# 如報錯　ImportError: No module named djcelery　，是因為沒有在虛擬環(huán)境運行導致，　workon h2進入虛擬環(huán)境再運行解決
import djcelery

#　初始化所有的task任務，這些任務來自booktest.task模塊
djcelery.setup_loader()

# 使用redis第０個數(shù)據(jù)庫，并綁定ip端口
BROKER_URL='redis://127.0.0.1:6379/0'

#　設置初始化的任務來源
CELERY_IMPORTS = 'booktest.task'

３　在應用目錄booktest下面創(chuàng)建任務列表文件task.py

from celery import task
import time

# 加上@task裝飾器，則python函數(shù)就變成一個celery任務
@task
def celery_test():
  print('hello...')
  time.sleep(5)
  print('world...')

４　創(chuàng)建視圖，并配置相關的url配置，把耗時任務放入視圖被調用

#　-*- coding:utf-8 -*-
from django.shortcuts import render
from django.http import HttpResponse
from task import celery_test


# celery練習１：把耗時程序放在celery中執(zhí)行
def celerytest(request):
  # function.delay(參數(shù)),celery任務celery_test調用方法
  celery_test.delay()
  return HttpResponse('ok')

# 根級url配置 test.urls
from django.conf.urls import include, url
from django.contrib import admin

urlpatterns = [
  url(r'^admin/', include(admin.site.urls)),
  url(r'^celery/', include('booktest.urls')),
]

# 應用下的url配置?。鈕oktest.urls
from django.conf.urls import url
import views

urlpatterns=[
  url(r'^celerytest/$', views.celerytest)
]

５　遷移，生成celery所需的數(shù)據(jù)表

python manage.py migrate

６　啟動redis

sudo redis-server /etc/redis/redis.conf

7　啟動worker

python manage.py celery worker --loglevel=info

8　另開一個終端窗口，啟動ｄjango服務器

python manage.py runserver

9 測試，輸入url，如　http://127.0.0.1:8000/celery/celerytest/，則返回'ok'

同時，會在worker對應的窗口看到耗時任務程序在此輸出，即當用戶請求時，不用等待太久就可以得到結果'ok'，同時耗時任務程序也被異步執(zhí)行，提高用戶體驗．

以上是“django之如何使用celery把耗時程序放到celery里面執(zhí)行”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業(yè)資訊頻道！