快捷導(dǎo)航

django之使用celery-把耗時(shí)程序放到celery里面執(zhí)行的方法

更新時(shí)間：2019年07月12日 11:57:48 作者：qq_19339041

今天小編就為大家分享一篇django之使用celery-把耗時(shí)程序放到celery里面執(zhí)行的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

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

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

2　配置settings，

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

# 注冊(cè)djcelery應(yīng)用
INSTALLED_APPS = (
  ...
  'djcelery',
)

# celery配置

# 如報(bào)錯(cuò)　ImportError: No module named djcelery　，是因?yàn)闆](méi)有在虛擬環(huán)境運(yùn)行導(dǎo)致，　workon h1進(jìn)入虛擬環(huán)境再運(yùn)行解決
import djcelery

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

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

#　設(shè)置初始化的任務(wù)來(lái)源
CELERY_IMPORTS = 'booktest.task'

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

from celery import task
import time

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

４　創(chuàng)建視圖，并配置相關(guān)的url配置，把耗時(shí)任務(wù)放入視圖被調(diào)用

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


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

# 根級(jí)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')),
]

# 應(yīng)用下的url配置　ｂooktest.urls
from django.conf.urls import url
import views

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

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

python manage.py migrate

６　啟動(dòng)redis

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

7　啟動(dòng)worker

python manage.py celery worker --loglevel=info

8　另開(kāi)一個(gè)終端窗口，啟動(dòng)ｄjango服務(wù)器

python manage.py runserver

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

同時(shí)，會(huì)在worker對(duì)應(yīng)的窗口看到耗時(shí)任務(wù)程序在此輸出，即當(dāng)用戶(hù)請(qǐng)求時(shí)，不用等待太久就可以得到結(jié)果'ok'，同時(shí)耗時(shí)任務(wù)程序也被異步執(zhí)行，提高用戶(hù)體驗(yàn)．

以上這篇django之使用celery-把耗時(shí)程序放到celery里面執(zhí)行的方法就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: