Windows安装部署启动Celery,python

Windows安装部署启动Celery,python

（1）首先需要在Windows中启动redis：

Windows环境搭建最新版NoSQL数据库Redis数据存储服务_zhangphil的博客-CSDN博客（1）下载安装最新Windows版的Redis。Redis官方目前没有直接给出Windows版本的发行版本，网上一搜，给出的多数是老旧的微软在2016年制作的Windows版本Redis发行版本。现在github上有一个，专注于Windows版本的Redis发行，跟进比较及时，最新版的Redis之Windows版本，链接地址：Releases · tporadowski/redis · GitHubhttps://github.com/tporadowski/redis/releases下载解压https://blog.csdn.net/zhangphil/article/details/122535147

（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结果。