使用rabbitmq-c库的AMQP客户端。
项目描述
- 版本：:
- 2.0.0
- 下载：:
- 代码：:
- 关键词：:
rabbitmq, amqp, 消息传递, librabbitmq, rabbitmq-c, python, kombu, celery
Python 绑定到 RabbitMQ C 库 rabbitmq-c。由 Kombu 和 Celery 支持。
安装
通过 pip 安装
$ pip install librabbitmq
或者，通过 easy_install 安装
$ easy_install librabbitmq
从源代码下载和安装
- 从以下地址下载最新版本
然后按照以下步骤进行安装
$ tar xvfz librabbitmq-0.0.0.tar.gz $ cd librabbitmq-0.0.0 $ python setup.py build # python setup.py install # as root
使用开发版本
您可以通过以下步骤克隆仓库
$ git clone git://github.com/celery/librabbitmq.git
然后按照以下步骤进行安装
$ cd librabbitmq $ make install # or make develop
示例
与 Kombu 一起使用
>>> from kombu import Connection
>>> x = Connection("librabbitmq://")
独立
>>> from librabbitmq import Connection >>> 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)
生产
>>> channel.basic_publish(body, exchange, routing_key, ...)
消费
>>> def dump_message(message):
... print("Body:'%s', Properties:'%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 文件。
关闭
librabbitmq-2.0.0.tar.gz 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | ffa2363a860ab5dcc3ce3703247e05e940c73d776c03a3f3f9deaf3cf43bb96c |
|
| MD5 | 8b7d127fee592eaa1fecd93839ae1cc7 |
|
| BLAKE2b-256 | f44e8f8bf33d44f3441d6f6c29b299cc847570b2c864bd8d2f9871aa6c03b73e |
关闭
librabbitmq-2.0.0-cp36-cp36m-manylinux1_x86_64.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 5cdfb473573396d43d54cef9e9b4c74fa3d1516da51d04a7b261f6ef4e0bd8be |
|
| MD5 | a460ca38aac94e5646f940655f0a17c2 |
|
| BLAKE2b-256 | cef72dd0d069f0591fccb1140dea73e43272943b5ff87da044119e037812cb05 |
关闭
librabbitmq-2.0.0-cp35-cp35m-manylinux1_x86_64.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 98e355f486964dadae7e8b51c9a60e9aa0653bbe27f6b14542687f305c4c3652 |
|
| MD5 | ae1e56d298f2c5796524e9b1285673f8 |
|
| BLAKE2b-256 | 431e888817ac962e1c888d87af7f78a1f9eba841c0545b146c410f716277c54a |
关闭
librabbitmq-2.0.0-cp34-cp34m-manylinux1_x86_64.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | cd9cc09343b193d7cf2cff6c6a578061863bd986a4bdf38f922e9dc32e15d944 |
|
| MD5 | 75b8e579b6f97b5c27e04941f5f219c3 |
|
| BLAKE2b-256 | ebfd7738795dae1beea24036fa8609841c552514cb3b79775f7f45bee226e74a |
关闭
librabbitmq-2.0.0-cp27-cp27mu-manylinux1_x86_64.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 3116e40c02d4285b8dd69834e4cbcb1a89ea534ca9147e865f11d44e7cc56eea |
|
| MD5 | d62a225adc342c70ccd680b4a2a15085 |
|
| BLAKE2b-256 | cc6021de22227f7b15637010614498844311c6baef319913b03fcc4cc6728d34 |
关闭
librabbitmq-2.0.0-cp27-cp27m-manylinux1_x86_64.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | c2a8113d3c831808d1d940fdf43e4882636a1efe2864df7ab3bb709a45016b37 |
|
| MD5 | 53d0bbc225504de718c3f29cfe2510c1 |
|
| BLAKE2b-256 | 165f6acb0d17f4a1fb33bd146b16b1666339c6b13da8a6429f627e5d8148ed40 |