django之使用celery-把耗时程序放到celery里面执行的方法
1在虚拟环境创建项目test和应用booktest（过程省略），然后安装所需的包
pipinstallcelery==3.1.25 pipinstallcelery-with-redis==3.0 pipinstalldjango-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:Nomodulenameddjcelery，是因为没有在虚拟环境运行导致，workonh1进入虚拟环境再运行解决
importdjcelery
#初始化所有的task任务，这些任务来自booktest.task模块
djcelery.setup_loader()
#使用redis第０个数据库，并绑定ip端口
BROKER_URL='redis://127.0.0.1:6379/0'
#设置初始化的任务来源
CELERY_IMPORTS='booktest.task'
３在应用目录booktest下面创建任务列表文件task.py
fromceleryimporttask
importtime
#加上@task装饰器，则python函数就变成一个celery任务
@task
defcelery_test():
print('hello...')
time.sleep(5)
print('world...')
４创建视图，并配置相关的url配置，把耗时任务放入视图被调用
#-*-coding:utf-8-*-
fromdjango.shortcutsimportrender
fromdjango.httpimportHttpResponse
fromtaskimportcelery_test
#celery练习１：把耗时程序放在celery中执行
defcelerytest(request):
#function.delay(参数),celery任务celery_test调用方法
celery_test.delay()
returnHttpResponse('ok')
#根级url配置test.urls
fromdjango.conf.urlsimportinclude,url
fromdjango.contribimportadmin
urlpatterns=[
url(r'^admin/',include(admin.site.urls)),
url(r'^celery/',include('booktest.urls')),
]
#应用下的url配置ｂooktest.urls
fromdjango.conf.urlsimporturl
importviews
urlpatterns=[
url(r'^celerytest/$',views.celerytest)
]
５迁移，生成celery所需的数据表
pythonmanage.pymigrate
６启动redis
sudoredis-server/etc/redis/redis.conf
7启动worker
pythonmanage.pyceleryworker--loglevel=info
8另开一个终端窗口，启动ｄjango服务器
pythonmanage.pyrunserver
9测试，输入url，如http://127.0.0.1:8000/celery/celerytest/，则返回'ok'
同时，会在worker对应的窗口看到耗时任务程序在此输出，即当用户请求时，不用等待太久就可以得到结果'ok'，同时耗时任务程序也被异步执行，提高用户体验．
以上这篇django之使用celery-把耗时程序放到celery里面执行的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。