window下搭建celery+rabbitmq 分布式任务调度

2021-04-10 04:26

阅读：634

标签：span www 安装 localhost rom err inf RKE code

环境搭建：

1. 安装celery4.0版本以上

2.安装erlang的运行环境，因为rabbitmq是基于erlang环境的; 下载链接:http://www.erlang.org/download.html

3. 安装rabbitmq ，下载链接：http://www.rabbitmq.com/download.htm

demo测试：

　　创建tasks.py

from celery import Celery

app = Celery(‘tasks‘,backend=‘‘,broker=‘amqp://guest@localhost//‘)

@app.task
def add(x, y):
    return x + y

在项目根目录下面的命令行里运行：celery -A tas worker --loglevel=info启动任务

然后打开python的命令行模式：

>>>from tasks inport add

>>>add.delay(1,3)

运行之后就会在cmd的那个窗口里面打印日志的

如果运行的时候报错ValueError: need more than 0 values to unpack

则用celery -A tas worker --loglevel=info -P eventlet启动任务，官网说是4以上版本就有这问题，具体可以参考这个https://github.com/celery/celery/issues/4081

from celery import Celeryapp = Celery(‘tasks‘,backend=‘‘,broker=‘amqp://guest@localhost//‘)
@app.task
def add(x, y):
return x + y

window下搭建celery+rabbitmq 分布式任务调度

标签：span www 安装 localhost rom err inf RKE code

原文地址：https://www.cnblogs.com/Huangsh2017Come-on/p/9052637.html

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：window下搭建celery+rabbitmq 分布式任务调度
文章链接：http://soscw.com/index.php/essay/73631.html

亲，登录后才可以留言！