Windows安装部署启动Celery,python

Posted zhangphil

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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结果。

以上是关于Windows安装部署启动Celery,python的主要内容,如果未能解决你的问题,请参考以下文章

windows安装celery时报错

celery使用方法中遇见的问题

celery异步,延时任务, 周期任务

celery-rabbitmq 安装部署

Win10下Celery4.2.1基于redis的部署与错误

python测试开发django-179.Dockerfile部署django和celery服务