1 在虚拟环境创建项目test和应用booktest(过程省略),然后安装所需的包
pip install celery==3.1.25 pip install celery-with-redis==3.0 pip install django-redis==3.1.17
2 配置settings,
# 数据库使用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 ,是因为没有在虚拟环境运行导致, workon h1进入虚拟环境再运行解决 import djcelery # 初始化所有的task任务,这些任务来自booktest.task模块 djcelery.setup_loader() # 使用redis第0个数据库,并绑定ip端口 BROKER_URL='redis://127.0.0.1:6379/0' # 设置初始化的任务来源 CELERY_IMPORTS = 'booktest.task'
3 在应用目录booktest下面创建任务列表文件task.py
from celery import task import time # 加上@task装饰器,则python函数就变成一个celery任务 @task def celery_test(): print('hello...') time.sleep(5) print('world...')
4 创建视图,并配置相关的url配置,把耗时任务放入视图被调用
# -*- coding:utf-8 -*- from django.shortcuts import render from django.http import HttpResponse from task import celery_test # celery练习1:把耗时程序放在celery中执行 def celerytest(request): # function.delay(参数),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配置 booktest.urls from django.conf.urls import url import views urlpatterns=[ url(r'^celerytest/$', views.celerytest) ]
5 迁移,生成celery所需的数据表
python manage.py migrate
6 启动redis
sudo redis-server /etc/redis/redis.conf
7 启动worker
python manage.py celery worker --loglevel=info
8 另开一个终端窗口,启动django服务器
python manage.py runserver
9 测试,输入url,如 http://127.0.0.1:8000/celery/celerytest/,则返回'ok'
同时,会在worker对应的窗口看到耗时任务程序在此输出,即当用户请求时,不用等待太久就可以得到结果'ok',同时耗时任务程序也被异步执行,提高用户体验.
以上这篇django之使用celery-把耗时程序放到celery里面执行的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。