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
#配置celery
import djcelery
djcelery.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 os
import django
from celery import Celery
from 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.py kombu/transport/redis.py celery/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 @task
def say(x,y):
time.sleep(5)
return x+y
然后再视图上写着写代码 然后配一个路由 启动Django服务和celery服务就可以了
#导入异步方法
from mymac.tasks import say def celery_test(request): print(say.delay('',''))
return HttpResponse('异步测试')
实现效果就是这样
同时打开三个命令窗口 ,一个是异步,一个是定时,一个是启动服务的
我们可以查看现在的定时状态,现在最流行的是supervisor ,
不过呢我要讲的是flower
首先现下载 pip install flower
然后在黑窗口上启动命令
python manage.py celery flower
在网页上查看