博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
djang-异步——定时操作
阅读量:4608 次
发布时间:2019-06-09

本文共 2468 字,大约阅读时间需要 8 分钟。

django本身是一个同步框架,flask也是,所以要把它变成异步操作的话还得专门设置一下

我的这个系统呢是windows系统,python3.7的

所以有的库是不可以兼容的 ,然后到时候会稍微修改一下源码

 

首先呢 先安装

pip install celery

pip install celery-with-redis

pip install django-celery

这三个库,然后要注意的是redis的版本不能超过3.0 ,必须是3.0一下的   , 不然的话不能兼容

要是有redis库的话 我们可以先卸载,然后可以指定安装redis库

pip uninstall redis

pip install redis==2.10.6

 

#给项目设置celery

#配置celeryimport djcelerydjcelery.setup_loader()BROKER_URL = 'redis://127.0.0.1:6379'CELERY_IMPORTS = ('mymac.tasks')

 

#设置INSTALLED_APPS

INSTALLED_APPS = [    'django.contrib.admin',    'django.contrib.auth',    'django.contrib.contenttypes',    'django.contrib.sessions',    'django.contrib.messages',    'django.contrib.staticfiles',    'mymac',    'myapp',    'myapp1',    #跨域    'corsheaders',    #异步    'djcelery']

 

#创建一个celery.py文件跟项目同级的   , 就是mymac项目里边的mymac文件夹里边

#导包import osimport djangofrom celery import Celeryfrom django.conf import settings os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mymac.settings')django.setup()app = Celery('mymac')app.config_from_object('django.conf:settings')app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)@app.task(bind=True)def debug_task(self):    print('Request: {0!r}'.format(self.request))

 

启动服务的命令:

celery -A mymac beat -l info 定时任务

celery -A mymac worker -l info 异步任务

python manage.py celery flower  查看状态

 

 ##值得注意的是我在上面说过会不兼容的,在python2.0里async不是关键字,而在python3.0是关键字

所以到时候启动命令的时候就会报错,所以那个文件报错就改那个文件就可以了

 

先找到 C:\Python37\Lib\site-packages\celery\utils路径     python路径

里面有一个timer2.py文件  我用的是vscode编程软件   , 然后用vscode打开这个文件,就会出现这个界面,然后按Ctrl+f 会出现查找   我的已经改过了所以是无结果的

像我一样写async 和 async_my   然后点那个红圈 就可以全部替换了  , 不用一个个替换

 

 

 这些路径都是python路径

 然后把这些也改完   跟上面的步骤一样

celery/utils/timer2.py/concurrency/asynpool.pykombu/transport/redis.pycelery/worker/auto_scale.py,components,consumer,strategy

把这些文件里面的async都改成async_my  ,这个是随便命名的 

 

 

 

我这里有个异步按例

首先先创建一个tasks.py 文件

 

#导报import time #导入异步任务from celery.task import task#导入定时任务库from celery.decorators import periodic_task#利用参数来设置任务周期@periodic_task(run_every=10)def some_task():    print('每十秒执行一次')    time.sleep(5)      print('执行完毕')    return True@taskdef say(x,y):    time.sleep(5)    return x+y

 

 然后再视图上写着写代码   然后配一个路由  启动Django服务和celery服务就可以了 

 

#导入异步方法from mymac.tasks import saydef celery_test(request):    print(say.delay('123','123'))    return HttpResponse('异步测试')

实现效果就是这样

 

 

同时打开三个命令窗口 ,一个是异步,一个是定时,一个是启动服务的

 

我们可以查看现在的定时状态,现在最流行的是supervisor ,

不过呢我要讲的是flower

首先现下载  pip install  flower

然后在黑窗口上启动命令

python manage.py celery flower

 

在网页上查看

 

转载于:https://www.cnblogs.com/weifeng-888/p/10557443.html

你可能感兴趣的文章
Unity3D热更新之LuaFramework篇[05]--Lua脚本调用c#以及如何在Lua中使用Dotween
查看>>
JavaScript空判断
查看>>
洛谷 P1439 【模板】最长公共子序列(DP,LIS?)
查看>>
python timeit
查看>>
Wireless Network 并查集
查看>>
51nod 1019 逆序数
查看>>
20145202马超《JAVA》预备作业1
查看>>
云推送注意(MSDN链接)
查看>>
OpenMobile's Application Compatibility Layer (ACL)
查看>>
竞价广告系统-广告检索
查看>>
强哥PHP面向对象学习笔记
查看>>
[转]基于.NET平台常用的框架整理
查看>>
Symbian (Read Inbox)读取收件箱的内容
查看>>
良好的编程规范
查看>>
struts2 入门
查看>>
.net 编译原理
查看>>
mean 快速开发和现有技术的对比分析
查看>>
Metro Style app :浏览器扩展
查看>>
linux的kernel是怎样工作的(TI_DM36X_ARM系统)(1)
查看>>
[luogu4310] 绝世好题 (递推)
查看>>