librabbitmq-c的Python绑定
项目描述
- 版本:
- 0.5.0
- 下载:
- 代码:
- 关键词:
rabbitmq, amqp, messaging, librabbitmq, rabbitmq-c, python
对RabbitMQ C库librabbitmq的实验性Python绑定。
你可能应该使用amqplib，但如果需要，并且需要额外的性能，可以回到这里。
安装
要安装，需要编译librabbitmq
$ mkdir -p /opt/Build/rabbit $ cd /opt/Build/rabbit $ hg clone http://hg.rabbitmq.com/rabbitmq-codegen/ $ hg clone http://hg.rabbitmq.com/rabbitmq-c/ $ cd rabbitmq-c $ autoreconf -i $ ./configure $ make $ make install
然后您可以安装此软件包
$ cd pylibrabbitmq-x.x.x $ python setup.py install
示例
>>> from pylibrabbitmq import Connection, Message>>> conn = Connection(host="localhost", userid="guest", ... password="guest", virtual_host="/")>>> channel = conn.channel() >>> channel.exchange_declare(exchange, type, ...) >>> channel.queue_declare(queue, ...) >>> channel.queue_bind(queue, exchange, routing_key)
生产
>>> m = Message(body, content_type=None, content_encoding=None, ... delivery_mode=1) >>> channel.basic_publish(m, exchange, routing_key, ...)
消费
>>> def dump_message(message): ... print("Body:'%s', Proeprties:'%s', DeliveryInfo:'%s'" % ( ... message.body, message.properties, message.delivery_info)) ... message.ack()>>> channel.basic_consume(queue, ..., callback=dump_message)>>> while True: ... connection.drain_events()
轮询
>>> message = channel.basic_get(queue, ...)
>>> if message:
... dump_message(message)
... print("Body:'%s' Properties:'%s' DeliveryInfo:'%s'" % (
... message.body, message.properties, message.delivery_info))
其他
>>> channel.queue_unbind(queue, ...) >>> channel.close() >>> connection.close()
许可协议
本软件根据Mozilla公共许可协议授权。请参阅顶部分发目录中的LICENSE-MPL-RabbitMQ文件以获取完整的许可协议文本。
关闭
pylibrabbitmq-0.5.0.tar.gz的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | a22d57fcd4e8dfa289b5a8921c6d869170347b07b4116e420e1dac20fa6e7662 |
|
| MD5 | 4e666893fed0f8d1d6e07a22707dca01 |
|
| BLAKE2b-256 | 778e297cb11400939280c407a8701bac9bba96c8e80964b0285551dd80a91ef7 |
