通过关注基于主题交换的设计模式,简化了与rabbitmq的交互。

thumper的Python项目详细描述


通过关注基于主题的设计模式简化与rabbitmq的交互 交换更多信息请访问: http://www.rabbitmq.com/tutorials/tutorial-five-python.html

目标

接受Kenneth Reitz的thoughts on the 90% rule,即请求模块

根据需要对消息进行序列化,从字符串没有序列化到json,如果更多,则返回到yaml。 简单的开放序列化方法无法序列化对象/消息。即日期时间/日期/十进制/等。

#!/usr/bin/env pythonfromrabbitimportProducerwithProducer(uri)asproducer:formessagein<iterable/generator>:producer.publish(message,routing_key)
fromrabbitimportConsumerwithConsumer(uri,exchange,queue,routing_key)asconsumer:consumer.attach_action(...)consumer.handle_messages(...)

或者为了更好地控制交换机和队列:

fromrabbitimportConsumerwithConsumer(uri)asconsumer:consumer.declare_exchange(...)consumer.declare_queue(...)consumer.attach_action(...)consumer.handle_messages(...)

uri是格式为mq://user:pass@host/vhost的消息队列uri,其中mq://user:pass@localhost==mq://user:pass@localhost/

在uri中,您可以传递用户、密码、主机、端口和vhost信息。有关详细信息,请参见thumper/test/test_mquri.py

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java Admob不使用webview   Java Wicket表单:序列化对象类“myClassName”时出错   java googledriveapi更新文件与我的帐户管理员   java简单框架未知xml标记解析   java如何使用主类和用户获取Spark应用程序ID   java如何更改自定义属性的值?   java有没有办法在jMock中找到未使用的期望值?   gradle运行任务的java文档?   java通过使用数组来存储文本文件的行,通过覆盖来删除文本文件中的行   用于表达式语言注入的java利用负载   java IDEStyle程序运行   java在运行时启用/禁用Springws   爪哇芦苇。formatNumber NullPointException   java为什么我的代码无法检测两个动态实体之间的碰撞?