django常用模块(django celery redis使用具体实践)
类别:脚本大全 浏览量:1573
时间:2021-10-20 08:40:26 django常用模块
django celery redis使用具体实践环境准备
- python3.5.4
- windows redis
- pip install celery
- pip install redis
windows下启动redirs server
redis-server.exe redis.windows.conf
celery配置
项目的settings.py文件修改:
|
# celery 设置 # celery中间人 redis://redis服务所在的ip地址:端口/数据库号 broker_url = 'redis://127.0.0.1:6379/0' # celery结果返回,可用于跟踪结果 celery_result_backend = 'redis://127.0.0.1:6379/0' # celery内容等消息的格式设置 celery_accept_content = [ 'application/json' , ] celery_task_serializer = 'json' celery_result_serializer = 'json' # celery时区设置,使用settings中time_zone同样的时区 celery_timezone = time_zone |
项目文件夹下添加celery.py文件:
|
# coding:utf-8 from __future__ import absolute_import, unicode_literals from celery import celery from django.conf import settings import os # 获取当前文件夹名,即为该django的项目名 project_name = os.path.split(os.path.abspath( '.' ))[ - 1 ] project_settings = '%s.settings' % project_name # 设置环境变量 os.environ.setdefault( 'django_settings_module' , project_settings) # 实例化celery,网上很多教程这里都是没有设置broker造成启动失败 app = celery( 'tasks' , broker = 'redis://127.0.0.1:6379/0' ) # 使用django的settings文件配置celery app.config_from_object( 'django.conf:settings' ) # celery加载所有注册的应用 app.autodiscover_tasks( lambda : settings.installed_apps) |
项目的init.py文件修改:
|
# 引入celery实例对象 from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ['celery_app] |
测试代码
- 如:在app01(项目名)/tasks.py:
- 关于task,并不是一定要把所有的task放在tasks.py,可以放在其他类里面,只要在函数上加@task即可
|
import time from celery import task @task def add(a,b): print ( "这是任务开始" ) print (a + b) time.sleep( 10 ) print ( "这是任务结束" ) |
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' : '这是一个后台任务' } return jsonresponse(result) |
再次配置
在manger.py目录执行下面的代码,注意网上的资料大部分执行的命令有问题,造成启动报错,比如这个就是错误的, python manage.py celery -a celery worker --loglevel=info
,请用下面的命令
|
celery - a djangoapi worker - - pool = solo - l info |
启动项目, python manager.py runserver 0.0.0.0:8081
运行项目
访问add
查看关键日志
|
[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] 这是任务开始 [ 2019 - 04 - 07 13 : 29 : 56 , 895 : warning / mainprocess] 3 [ 2019 - 04 - 07 13 : 30 : 06 , 896 : warning / mainprocess] 这是任务结束 [ 2019 - 04 - 07 13 : 30 : 06 , 898 : info / mainprocess] task api.tasks.add[ 9fd98fd0 - 50ae - 427f - 8f33 - 52d1e4b43068 ] succeeded in 10.0s : none |
其他
如何结合前端,如ajax来联合使用?
- 表中我加了个extend字段,每次在执行耗时任务后,页面按钮根据extend字段值进行判断
- 如1表示执行中,0表示没有执行,2执行完成,来判定按钮是否可以再次点击等
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
原文链接:https://www.jianshu.com/p/0fe3479f5f3f
您可能感兴趣
- docker装redis(通过Docker部署Redis 6.x集群的方法)
- 查看linux上是否安装redis(Linux安装Redis实现过程及报错解决方案)
- phpredis高级用法(PHP Redis扩展无法加载的问题解决方法)
- dockermysql配置详解(Docker 部署Mysql 服务和Redis 服务的方法)
- docker查找redis配置文件(解决docker重启redis,mysql数据丢失的问题)
- php redis配置(php+redis实现消息队列功能示例)
- phpredis消息队列(PHP+redis实现微博的推模型案例分析)
- yield函数详解(Yii框架的redis命令使用方法简单示例)
- php实现redis核心代码(PHP结合Redis+MySQL实现冷热数据交换应用案例详解)
- docker容器使用redis服务(在Docker中使用Redis的步骤详解)
- pythonredis使用场景(python 通过SSHTunnelForwarder隧道连接redis的方法)
- docker redis安装配置(在docker中部署并启动redis的方法)
- docker快速配置redis集群(基于docker搭建redis集群的方法)
- redis新增数据分页(Scrapy-Redis结合POST请求获取数据的方法示例)
- docker容器使用redis服务(docker安装redis设置密码并连接的操作)
- php消息队列redis(redis+php实现微博二发布与关注功能详解)
- 谢娜是得罪快乐大本营造型师了吗 全场被黑化(谢娜是得罪快乐大本营造型师了吗)
- 前《iLOOK》时装总监 《快乐大本营》御用造型师上线(快乐大本营御用造型师上线)
- 释小龙晒杀青照片 多重身份惹观众期待(释小龙晒杀青照片)
- 《九牛之人降魔传》开机 演员祁高坤化身九牛之人除魔卫道(九牛之人降魔传开机)
- 王铲铲的致富之路无限金币卡法攻略教学(王铲铲的致富之路无限金币卡法攻略教学)
- 文明6金币太少怎么办 文明6无限刷钱教程(文明6金币太少怎么办)
热门推荐
- python随机生成时间戳(python时间序列按频率生成日期的方法)
- 远程登录linux服务器(linux云服务器怎么登录?)
- css弹性布局设置每行显示指定个数(CSS实现多行多列的布局的实例代码)
- html5布局(Html5让容器充满屏幕高度或自适应剩余高度的布局实现)
- mysql数据表怎么复制(MySQL 复制表的方法)
- CSS设置字体
- css3怎么构建阴影(详解css3 mask遮罩实现一些特效)
- php错误提示问题(php提示Creating default object from empty value 的问题解决方法)
- MVC上传文件的方法
- 为什么dede主页加载不出来(dede中第一次登陆密码错误的解决方法)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9