本文主要介绍如何在django中用celery完成异步任务，web项目中为了提高用户体验可以对一些耗时操作放到异步队列中去执行，例如激活邮件，后台计算操作等等 当前项目环境为： django==1.11.8 celery==3.1.25 redis==2.10.6 pip==9.0.1 python3==3.5.2 django-celery==3.1.17
一，创建Django项目及celery配置
1，创建Django项目
1>打开终端输入：django-admin startproject TestCelery 创建django项目('TestCelery'是项目名称)
2>进行TestCelery在终端输入指令：django-admin startapp testcelery 创建应用('testcelery为应用名称')
2， 为celery设置环境变量
1>项目中在TestCelery中创建celery.py文件(与setting.py同级)输入以下内容：
from celery import Celery
from django.conf import settings
import os
# 为celery设置环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'TestCelery.settings')
# 创建应用
app = Celery('testcelery')
# 酸配置应用
app.conf.update(
# 本地Redis服务器
BROKER_URL='redis://127.0.0.1:6379/2',
)
app.autodiscover_tasks(settings.INSTALLED_APPS)
2>当前项目目录如下图所示：
二,创建任务tasks,编写视图View及urls
1, 在testcelery应用中新建tasks.py文件，并写入要进行处理的任务：
from TestCelery.celery import app
from time import sleep
@app.task
def start_running(nums):
print('***>%s<***' %nums)
print('---开始执行任务<<---')
for i in range(10):
print(''*(i+1))
sleep(1)
print('>---任务结束---<')
2，编写view视图，并写入调用client的方法
from django.views import View
from django.http import HttpResponse
from .tasks import start_running
from time import sleep
# Create your views here.
class IdexView(View):
def get(self, request):
print('>=====开始发送请求=====<')
for i in range(10):
print('',end='')
sleep(0.1)
start_running.delay('》》》》》我是传送过来的《《《《《')
return HttpResponse('<h2> 请求已发送 </h2>')
3，编写testcelery应用的usrls
from django.conf.urls import url from .views import * urlpatterns = [ url(r'^$', IdexView.as_view()), ]
4，当前项目目录如下图所示：
三，运行项目，开启worker
1, 运行项目在当前项目下输入启动服务指令：python manager.py runserver，出现如下图所示即代表运行成功：
2，开启worker另在当前项目下另打开一个终端，输入指令: celery -A TestCelery worker --loglevel=DEBUG,启动后如下如示：
3，调用任务
1>打开浏览器，输入http://127.0.0.1:8000/send/ 进行访问
2> woker监听到任务请求时，就会执行耗时任务，如下图所示：
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。