这篇文章主要为大家展示了“django之如何使用celery把耗时程序放到celery里面执行”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“django之如何使用celery把耗时程序放到celery里面执行”这篇文章吧。
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 h2进入虚拟环境再运行解决
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里面执行”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。