快捷導(dǎo)航

django celery redis使用具體實(shí)踐

更新時(shí)間：2019年04月08日 08:25:06 作者：望月成三人

這篇文章主要介紹了django celery redis使用具體實(shí)踐，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

環(huán)境準(zhǔn)備

python3.5.4
windows redis
pip install celery
pip install redis

windows下啟動(dòng)redirs server

redis-server.exe redis.windows.conf

celery配置

項(xiàng)目的settings.py文件修改：

# celery 設(shè)置
# celery中間人 redis://redis服務(wù)所在的ip地址:端口/數(shù)據(jù)庫(kù)號(hào)
BROKER_URL = 'redis://127.0.0.1:6379/0'
# celery結(jié)果返回，可用于跟蹤結(jié)果
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/0'

# celery內(nèi)容等消息的格式設(shè)置
CELERY_ACCEPT_CONTENT = ['application/json', ]
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

# celery時(shí)區(qū)設(shè)置，使用settings中TIME_ZONE同樣的時(shí)區(qū)
CELERY_TIMEZONE = TIME_ZONE

項(xiàng)目文件夾下添加celery.py文件：

# coding:utf-8
from __future__ import absolute_import, unicode_literals

from celery import Celery
from django.conf import settings
import os

# 獲取當(dāng)前文件夾名，即為該Django的項(xiàng)目名
project_name = os.path.split(os.path.abspath('.'))[-1]
project_settings = '%s.settings' % project_name

# 設(shè)置環(huán)境變量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', project_settings)

# 實(shí)例化Celery,網(wǎng)上很多教程這里都是沒(méi)有設(shè)置broker造成啟動(dòng)失敗
app = Celery('tasks', broker='redis://127.0.0.1:6379/0')

# 使用django的settings文件配置celery
app.config_from_object('django.conf:settings')

# Celery加載所有注冊(cè)的應(yīng)用
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

項(xiàng)目的init.py文件修改：

# 引入celery實(shí)例對(duì)象
from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app
__all__ = ['celery_app]

測(cè)試代碼

如：在app01（項(xiàng)目名）／tasks.py：
關(guān)于task，并不是一定要把所有的task放在tasks.py，可以放在其他類(lèi)里面，只要在函數(shù)上加@task即可

import time
from celery import task
@task
def add(a,b):
  print("這是任務(wù)開(kāi)始")
  print(a+b)
  time.sleep(10)
  print("這是任務(wù)結(jié)束")

url配置如下：

path('add', views.add, name="add")

view代碼

from . import tasks
def add(request,*args,**kwargs):
  tasks.add.delay(1,2)
  result = {'code': 0, 'msg': '這是一個(gè)后臺(tái)任務(wù)'}
  return JsonResponse(result)

再次配置

在manger.py目錄執(zhí)行下面的代碼，注意網(wǎng)上的資料大部分執(zhí)行的命令有問(wèn)題，造成啟動(dòng)報(bào)錯(cuò)，比如這個(gè)就是錯(cuò)誤的， python manage.py celery -A celery worker --loglevel=info ，請(qǐng)用下面的命令

celery -A djangoApi worker --pool=solo -l info

啟動(dòng)項(xiàng)目, python manager.py runserver 0.0.0.0:8081

運(yùn)行項(xiàng)目

訪(fǎng)問(wèn)add

查看關(guān)鍵日志

[tasks]
 . api.base.BaseViewTask.task_run
 . api.tasks.add

[2019-04-07 13:26:02,855: INFO/MainProcess] Connected to redis://127.0.0.1:6379/0
[2019-04-07 13:26:02,869: INFO/MainProcess] mingle: searching for neighbors
[2019-04-07 13:26:03,911: INFO/MainProcess] mingle: all alone
[2019-04-07 13:26:03,926: WARNING/MainProcess] e:\app\python35\lib\site-packages\celery\fixups\django.py:202: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
 warnings.warn('Using settings.DEBUG leads to a memory leak, never '
[2019-04-07 13:26:03,926: INFO/MainProcess] celery@PC-20181208QWQO ready.
[2019-04-07 13:29:56,889: INFO/MainProcess] Received task: api.tasks.add[9fd98fd0-50ae-427f-8f33-52d1e4b43068]
[2019-04-07 13:29:56,894: WARNING/MainProcess] 這是任務(wù)開(kāi)始
[2019-04-07 13:29:56,895: WARNING/MainProcess] 3
[2019-04-07 13:30:06,896: WARNING/MainProcess] 這是任務(wù)結(jié)束
[2019-04-07 13:30:06,898: INFO/MainProcess] Task api.tasks.add[9fd98fd0-50ae-427f-8f33-52d1e4b43068] succeeded in 10.0s: None

其他

如何結(jié)合前端，如ajax來(lái)聯(lián)合使用？