码迷,mamicode.com
首页 > Windows程序 > 详细

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

时间:2018-05-17 19:15:09      阅读:28      评论:0      收藏:0      [点我收藏+]

标签: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://[email protected]//)

@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 Celery

app = Celery(‘tasks‘,backend=‘‘,broker=‘amqp://[email protected]//‘)

@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

(0)
(0)
   
举报
评论 一句话评论(0
0条  
登录后才能评论!
© 2014 mamicode.com 版权所有 京ICP备13008772号-2
迷上了代码!