- 浏览: 366285 次
- 性别:
- 来自: 长春
文章分类
- 全部博客 (319)
- java socket (1)
- java ,IT , (14)
- php Cannot send session cache limiter - headers already sent (1)
- java ,IT ,淘宝 (1)
- mysql java (1)
- wml wap (1)
- jsp (1)
- python (27)
- 第一种方法满足要求 (1)
- java android (2)
- 娱乐,经验 (0)
- java (1)
- 经验 (1)
- linux (4)
- mongodb (1)
- php (2)
- hadoop (1)
- 转载,分享 (1)
- django (1)
- mongo (1)
- java web project (1)
- python3 (1)
- go (1)
最新评论
-
lu56898:
ubuntu中 加了没效果唉
python解决 'ascii' codec can't encode characters -
cooler1217:
DiaoCow 写道不知道LZ想取什么? 但看了下LZ的gre ...
grep awk 应用 -
DiaoCow:
不知道LZ想取什么? 但看了下LZ的grep使用,想了下其实可 ...
grep awk 应用 -
cooler1217:
外国人叫:条条大路通罗马,中国人叫:小鸡不撒尿,各有各的道。完 ...
linux 更改yum地址 -
libla:
个人更喜欢debian极度鄙视yum这种依赖于第三方语言(py ...
linux 更改yum地址
此过程非常复杂 , 我就把整个过程记录下来 。。。
1 python2.7.2 安装。。。不解释
2 celery 安装 不解释 http://celeryproject.org/
3 例子 运行。。。 咔嚓,出错了。。。
异常:
:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\loaders\default.py:45: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python.
"is available to Python." % (configname, )))
原因:每个工程都要有celeryConfig.py
补上: 内容
4 继续运行 (做个梦。。。成功了)
现实比较残酷....
异常:
Traceback (most recent call last):
File "D:\workspace\testCelery\src\tasks.py", line 12, in <module>
result = add.delay(4,4)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\task\__init__.py", line 338, in delay
return self.apply_async(args, kwargs)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\task\__init__.py", line 444, in apply_async
publish = publisher or self.app.amqp.publisher_pool.acquire(block=True)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 666, in acquire
R = self.prepare(self.new())
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\pools.py", line 55, in prepare
p = p()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\pools.py", line 46, in <lambda>
return lambda: self.create_producer()
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 264, in create_producer
pub = self.app.amqp.TaskPublisher(conn, auto_declare=False)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 325, in TaskPublisher
return TaskPublisher(*args, **self.app.merge(defaults, kwargs))
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 157, in __init__
super(TaskPublisher, self).__init__(*args, **kwargs)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\compat.py", line 61, in __init__
super(Publisher, self).__init__(connection, self.exchange, **kwargs)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\messaging.py", line 69, in __init__
channel = channel.default_channel
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 593, in default_channel
self.connection
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 586, in connection
self._connection = self._establish_connection()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 546, in _establish_connection
conn = self.transport.establish_connection()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\transport\amqplib.py", line 252, in establish_connection
connect_timeout=conninfo.connect_timeout)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\transport\amqplib.py", line 62, in __init__
super(Connection, self).__init__(*args, **kwargs)
File "build\bdist.win32\egg\amqplib\client_0_8\connection.py", line 129, in __init__
File "build\bdist.win32\egg\amqplib\client_0_8\transport.py", line 281, in create_transport
File "build\bdist.win32\egg\amqplib\client_0_8\transport.py", line 85, in __init__
socket.error: [Errno 10061]
找啊找。。。什么原因呢?
思绪万千。。。乱乱乱。。。
叮咚: 你光有worker,没有消息队列。。。他肯定不知道干啥,因为你rabbitMq还没装。。。
5 开始装rabbitMq。。。 http://www.rabbitmq.com/download.html
下载,安装。。。请先安装erlang。。。。 http://www.erlang.org/download.html
好吧,继续下载erlang。。。。
等待ing。。。
等待ing。。。。。
6 安装erlang。。。bingo
安装rabbitMq。。。bingo
7 运行。。。还是不行,在研究。。。
bingo 找到了。。。
因为是任务模式,你启动了这个任务,就要新花一个程序调用这个任务,才会执行
我的是windows系统,所以比较麻烦。。
步骤如下:
1) 先进入工程目录
cd D:\workspace\testCelery\src
2)z执行命令,启动任务线程
python C:\Python27\Lib\site-packages\celery-2.4.6-py2.7.egg\celery\bin\celeryd.py -l info -I tasks
3) 然后在执行你编写的调用任务的python文件就可以了。。
测试:
>>> result = add.delay(4, 4)
>>> result.ready() # returns True if the task has finished processing.
False
>>> result.result # task is not ready, so no return value yet.
None
>>> result.get() # Waits until the task is done and returns the retval.
8
>>> result.result # direct access to result, doesn't re-raise errors.
8
>>> result.successful() # returns True if the task didn't end in failure.
True
大功告成~~~
总结 :
一、celery是调用rabbitMq的消息队列用的,所以必须先装rabbitMq,而rabbit是用erlang写的,还要装erlang环境,这个rabbitmq在安装的时候会进行提醒
二、先启动消息队列服务起rabbitmq,然后启动你编写的执行任务线程,然后在去编写任务去执行
三、windos每次在命令行下启动,不停的打路径,故写一个简单的批处理,进行任务启动 代码如下
D:
cd D:\workspace\testCelery\src
python C:\Python27\Lib\site-packages\celery-2.4.6-py2.7.egg\celery\bin\celeryd.py -l info -I tasks
语法就是不停的罗列你在命令行下输入的内容就行,然后命名为bat,双击执行,你的任务线程就启动了~~
一点分享,尊重原著,哈哈哈。。。
到此结束,开始应用!!
如果您觉得有用,记得赞一个,留言一下,对我鼓励一下~~
1 python2.7.2 安装。。。不解释
2 celery 安装 不解释 http://celeryproject.org/
3 例子 运行。。。 咔嚓,出错了。。。
异常:
:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\loaders\default.py:45: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python.
"is available to Python." % (configname, )))
原因:每个工程都要有celeryConfig.py
补上: 内容
import sys import os sys.path.insert(0, os.getcwd()) CELERY_IMPORTS = ("tasks", ) CELERY_RESULT_BACKEND = "amqp" BROKER_HOST = "localhost" BROKER_PORT = 5672 BROKER_USER = "guest" BROKER_PASSWORD = "guest" BROKER_VHOST = "/"
4 继续运行 (做个梦。。。成功了)
现实比较残酷....
异常:
Traceback (most recent call last):
File "D:\workspace\testCelery\src\tasks.py", line 12, in <module>
result = add.delay(4,4)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\task\__init__.py", line 338, in delay
return self.apply_async(args, kwargs)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\task\__init__.py", line 444, in apply_async
publish = publisher or self.app.amqp.publisher_pool.acquire(block=True)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 666, in acquire
R = self.prepare(self.new())
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\pools.py", line 55, in prepare
p = p()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\pools.py", line 46, in <lambda>
return lambda: self.create_producer()
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 264, in create_producer
pub = self.app.amqp.TaskPublisher(conn, auto_declare=False)
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 325, in TaskPublisher
return TaskPublisher(*args, **self.app.merge(defaults, kwargs))
File "C:\Python27\lib\site-packages\celery-2.4.6-py2.7.egg\celery\app\amqp.py", line 157, in __init__
super(TaskPublisher, self).__init__(*args, **kwargs)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\compat.py", line 61, in __init__
super(Publisher, self).__init__(connection, self.exchange, **kwargs)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\messaging.py", line 69, in __init__
channel = channel.default_channel
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 593, in default_channel
self.connection
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 586, in connection
self._connection = self._establish_connection()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\connection.py", line 546, in _establish_connection
conn = self.transport.establish_connection()
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\transport\amqplib.py", line 252, in establish_connection
connect_timeout=conninfo.connect_timeout)
File "C:\Python27\lib\site-packages\kombu-2.1.0-py2.7.egg\kombu\transport\amqplib.py", line 62, in __init__
super(Connection, self).__init__(*args, **kwargs)
File "build\bdist.win32\egg\amqplib\client_0_8\connection.py", line 129, in __init__
File "build\bdist.win32\egg\amqplib\client_0_8\transport.py", line 281, in create_transport
File "build\bdist.win32\egg\amqplib\client_0_8\transport.py", line 85, in __init__
socket.error: [Errno 10061]
找啊找。。。什么原因呢?
思绪万千。。。乱乱乱。。。
叮咚: 你光有worker,没有消息队列。。。他肯定不知道干啥,因为你rabbitMq还没装。。。
5 开始装rabbitMq。。。 http://www.rabbitmq.com/download.html
下载,安装。。。请先安装erlang。。。。 http://www.erlang.org/download.html
好吧,继续下载erlang。。。。
等待ing。。。
等待ing。。。。。
6 安装erlang。。。bingo
安装rabbitMq。。。bingo
7 运行。。。还是不行,在研究。。。
bingo 找到了。。。
因为是任务模式,你启动了这个任务,就要新花一个程序调用这个任务,才会执行
我的是windows系统,所以比较麻烦。。
步骤如下:
1) 先进入工程目录
cd D:\workspace\testCelery\src
2)z执行命令,启动任务线程
python C:\Python27\Lib\site-packages\celery-2.4.6-py2.7.egg\celery\bin\celeryd.py -l info -I tasks
3) 然后在执行你编写的调用任务的python文件就可以了。。
测试:
>>> result = add.delay(4, 4)
>>> result.ready() # returns True if the task has finished processing.
False
>>> result.result # task is not ready, so no return value yet.
None
>>> result.get() # Waits until the task is done and returns the retval.
8
>>> result.result # direct access to result, doesn't re-raise errors.
8
>>> result.successful() # returns True if the task didn't end in failure.
True
大功告成~~~
总结 :
一、celery是调用rabbitMq的消息队列用的,所以必须先装rabbitMq,而rabbit是用erlang写的,还要装erlang环境,这个rabbitmq在安装的时候会进行提醒
二、先启动消息队列服务起rabbitmq,然后启动你编写的执行任务线程,然后在去编写任务去执行
三、windos每次在命令行下启动,不停的打路径,故写一个简单的批处理,进行任务启动 代码如下
D:
cd D:\workspace\testCelery\src
python C:\Python27\Lib\site-packages\celery-2.4.6-py2.7.egg\celery\bin\celeryd.py -l info -I tasks
语法就是不停的罗列你在命令行下输入的内容就行,然后命名为bat,双击执行,你的任务线程就启动了~~
一点分享,尊重原著,哈哈哈。。。
到此结束,开始应用!!
如果您觉得有用,记得赞一个,留言一下,对我鼓励一下~~
- celery_rabbitmq.rar (3.4 MB)
- 下载次数: 16
发表评论
-
MacOS M1 安装rocketmq-client-python
2021-11-25 17:26 8521 下载 https://github.com/apache ... -
python克隆数据 copy
2013-03-07 14:16 897现在看到了 Python 优美的设计。那下面的问题是,如果我们 ... -
python Queue模块
2013-02-22 17:07 9412011-04-20 17:11:05| 分类: Pyth ... -
[emerg] 10464#0: unknown directive "ssl"
2013-02-01 11:57 3807#yum install openssl #yum insta ... -
python flask应用 Principal 授权认证
2012-12-14 11:56 1789''' Created on 2012-6-14 ... -
sitecustomize.py 用法
2012-11-19 15:48 23661、在python安装目录下的lib下的site-packag ... -
加菲小小小猫 python菜鸟侃大山第一弹--目录
2012-06-26 13:33 0欢迎来到加菲小小小猫菜鸟讲堂,这期课程共计20课时,主要内容为 ... -
加菲小小小猫 python菜鸟侃大山第一弹--目录
2012-06-26 11:06 4欢迎来到加菲小小小猫菜鸟讲堂,这期课程共计20 ... -
TypeError: 'module' object is not callable 解决
2012-04-17 16:03 3899原文地址:http://hi.baidu.com/bsndhs ... -
python 自定义py文件中方法导入
2012-04-06 14:45 2749例子: 工程 ... -
pymongo 模糊查询
2012-04-01 17:32 5813如果是mongodb的客户端下 直接输入命令 db.devi ... -
pymongo $addToSet 和 $set 区别
2012-03-28 15:35 2393conn = Connection("127 ... -
python解决 'ascii' codec can't encode characters
2012-03-27 18:08 12002异常: 'ascii' codec can't encode ... -
python mongodb time的妙用
2012-03-19 14:41 947需要把这条日志的时间放到临近的5分钟内, 时间段为:0,5,1 ... -
python ftp上传下载文件,支持断点续传
2012-03-14 11:41 4401功能:ftp断点上传下载 仅供参考: #encodin ... -
python 百分号使用
2012-03-09 12:17 3952原文地址 http://developer ... -
celery+ rabbitMq + python linux是下配置 序
2012-02-27 04:42 907我安装的时候就遇到了很多麻烦,主要是跟中linux包的依赖。。 ... -
logging 使用 python
2012-02-22 17:50 813转载:http://blog.csdn.net/yatere/ ... -
python **args * args
2012-02-20 18:12 737转载 http://jimi68.iteye.com/blo ... -
python paramiko pycropto 安装
2012-02-17 19:30 967http://www.voidspace.org.uk/pyt ...
相关推荐
Django+celery+rabbitmq配置文档
NULL 博文链接:https://cooler1217.iteye.com/blog/1559206
Sqlite3+RabbitMQ+Celery Python从零开始搭建一个生产者消费者服务模型配套安装文件
主要介绍了详解django+django-celery+celery的整合实战,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
在之前的一篇文章中提到了用Django+Celery+Redis实现了异步任务队列,只不过消息中间件使用了redis,redis作为消息中间件可谓是差强人意,功能和性能上都不如Rabbitmq,所以本次使用tornado框架结合celery,同时消息...
本项目是本人学习django+celery+redis+docker实战的项目。
基于 python + fastApi + celery + sqlalchemy + redis 使用软件版本 python version 3.9.6 mysql version 8.0.23 redis version 6.0.9 node version 18.15.0 前端 基于 vite + vue3 + element-plus 使用软件...
基于DjangoRestFramework+Celery+微信小程序实战开发(第一部分)
第一步,修改工厂函数,配置邮件参数 from flask import Flask from config import Config from flask_sqlalchemy import SQLAlchemy from flask_mail import Mail db = SQLAlchemy() mail = Mail() def create_app...
基于flask+celery+apscheduler实现的分布式定时任务源码.zip 该项目已完成多机验证可运行 windows mac linux 皆可 完成主要功能: 基于flask实现的web,celery实现异步以及任务分布式,aspchedluer实现定时任务以及...
centos6+python3.6+django2+ansible2.4+celery4.2 运维管理系统,目前实现功能:用户和用户组管理、资产管理、集成ansible2.4、简易堡垒机(主机分配支持rdp以及vnc、用户分配、文件上传下载、配置禁用命令清单、操作...
使用FastAPI和Celery以及RabbitMQ代理的分布式任务队列的工作示例。 安装 拉RabbitMQ图像 码头工人拉rabbitmq 用法 构建API和任务服务器映像 docker build -t celery_simple:latest。 运行API,代理和任务服务器 ...
教程网址:http://blog.csdn.net/win_turn/article/details/60658525
1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合...
人工智能-项目实践-异步调度-ActiveMQ+Celery异步任务调度,Python AI 开发调试 依赖环境 Python3, 推荐Python3.6 开发环境 PyCharm
基于 python 3.7.9 + django 2.2.16 + channels 2.4.0 + celery 4.4.7 + ansible 2.9.14 + AdminLTE-3.0.0 实现的运维 devops 管理系统。具体见 screenshots 文件夹中的效果预览图。 本人为运维工程师,非专业开发,...
性感的Django + python-telegram-bot + Celery + Redis + Postgres + Dokku + GitHub Actions模板。 生产量级的Telegram机器人,具有数据库,管理面板和许多有用的内置方法。 检查使用来自Main分支的代码的示例bot...