Windows安装部署启动Celery,python
Posted zhangphil
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Windows安装部署启动Celery,python相关的知识,希望对你有一定的参考价值。
Windows安装部署启动Celery,python
(1)首先需要在Windows中启动redis:
(2)安装必须的Celery依赖库:
pip install celery
pip install redis
pip install gevent
(3)写一批测试任务tasks.py:
import time
from celery import Celery
broker = 'redis://127.0.0.1:6379'
backend = 'redis://127.0.0.1:6379/1' #最后的1可以换成其他,表示在redis里面的数据库编号
app = Celery('my_task', broker=broker, backend=backend)
@app.task
def add(x, y):
time.sleep(5)
return x + y
将上述代码存入名为tasks.py的代码文件,至于tasks这个名字随意。
然后在tasks.py所在目录执行命令:
celery -A tasks worker -P gevent --loglevel=info
注意:在Windows下,如果不指定 -P gevent,celery收到任务但不执行,也就是说不会有任务执行结果。gevent并行库有一个替代的方案是eventlet,也可以 -P eventlet。如果使用eventlet,需要pip install eventlet
(4)接下来后可以使用上面定义的tasks.py里面的任务了:
from tasks import add
if __name__ == '__main__':
print('-')
result=add.delay(1, 2)
print('--')
运行后,在Windows下通过redis的 GUI工具即可查看此次任务存放的result结果。
以上是关于Windows安装部署启动Celery,python的主要内容,如果未能解决你的问题,请参考以下文章