Python RabbitMQ客户端
项目描述
基本的RabbitMQ Python连接器。
内容
简介
eea.rabbitmq.client是RabbitMQ服务器的连接器。
API
使用示例
from eea.rabbitmq.client import RabbitMQConnector
rabbit_config = {
'rabbit_host': "10.0.0.1",
'rabbit_port': "8080",
'rabbit_username': "admin",
'rabbit_password': "admin"
}
queue_name = "QUEUE_NAME"
rabbit = RabbitMQConnector(**rabbit_config)
rabbit.open_connection()
rabbit.declare_queue(queue_name)
rabbit.send_message(queue_name, "body text")
rabbit.close_connection()
字符串与字节
RabbitMQ消息是字节，尽管它们可能可选地具有编码标志。在Python 3中消费消息时，它们将以字节形式接收，并且应该进行解码
method, properties, body = rabbit.get_message(queue_name) message = body.decode(properties.content_encoding or 'ascii')
变更日志
1.9 - (2020-05-13)
功能：增加了Python3支持。[mgax refs #116195]
1.8 - (2019-01-28)
Jenkins：添加sonarqube步骤[avoinea refs #101552]
1.7 - (2018-09-24)
变更：删除RabbitMQ客户端的plone实用工具。（已在https://github.com/eea/eea.rabbitmq.plone中移动）[GhitaB refs #91506]
1.6 - (2018-08-21)
功能：为RabbitMQ客户端添加配置和实用工具[GhitaB refs #91506]
更改：更新了指向 eea.europa.eu 的 URL，并使用 https:// [alecghica 引用 #95849]
1.5 - (2017-12-12)
更改：将 eeacms/zptlint 替换为 eeacms/plone-test:4 zptlint [avoinea 引用 #90415]
1.4 - (2017-04-24)
更改：更新了软件包信息 [eduard-fironda]
1.3 - (2016-09-05)
错误修复：修复了 pylint [chiridra 引用 #72772]
1.2 - (2016-08-29)
更改：禁用了心跳间隔以避免断开连接。 [chiridra 引用 #72772]
1.1 - (2016-05-12)
更改：将软件包转换为合适的 plone 软件包 [ichim-david 引用 #71940]
1.0 - (2016-05-04)
特性：添加了文档 [alecghica 引用 #69689]
错误修复：修复了软件包结构 [alecghica 引用 #69689]
特性：初始发布 [szabozo0 引用 #69689]
关闭
eea.rabbitmq.client-1.9.zip 的散列
| 算法 | 散列摘要 | |
|---|---|---|
| SHA256 | 017b06e1abb81bb25b1f08dc29a582371173af3bf8531c98b892e0a8f72a3c72 |
|
| MD5 | 067e51cee56f40285476da42c4cdb59a |
|
| BLAKE2b-256 | ce28d747912528378cba51ace397092748d3ae027e1ba4223566ceb0d17c0b3a |