Skip to main content

Python bindings to librabbitmq-c

Project description

Version:
0.4.0
Download:

http://pypi.python.org/pypi/pylibrabbitmq/

Code:

http://github.com/ask/pylibrabbitmq/

Keywords:

rabbitmq, amqp, messaging, librabbitmq, rabbitmq-c, python

Experimental Python bindings to the RabbitMQ C-library librabbitmq.

You should probably use amqplib instead, but when needed you can come back to this if the extra performance is needed.

Installation

To install you need to compile 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

Then you can install this package:

$ cd pylibrabbitmq-x.x.x
$ python setup.py install

Examples

>>> 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)

Produce

>>> m = Message(body, content_type=None, content_encoding=None,
...             delivery_mode=1)
>>> channel.basic_publish(m, exchange, routing_key, ...)

Consume

>>> 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()

Poll

>>> message = channel.basic_get(queue, ...)
>>> if message:
...     dump_message(message)
...     print("Body:'%s' Properties:'%s' DeliveryInfo:'%s'" % (
...         message.body, message.properties, message.delivery_info))

Other

>>> channel.queue_unbind(queue, ...)
>>> channel.close()
>>> connection.close()

License

This software is licensed under the Mozilla Public License. See the LICENSE-MPL-RabbitMQ file in the top distribution directory for the full license text.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

pylibrabbitmq-0.4.0.tar.gz (47.8 kB view details)

Uploaded Source

File details

Details for the file pylibrabbitmq-0.4.0.tar.gz.

File metadata

File hashes

Hashes for pylibrabbitmq-0.4.0.tar.gz
Algorithm Hash digest
SHA256 0db55f73363beac25888026694efc8122ec677b2793349b2b7a105724891d5e2
MD5 573488b552c4379175b9e0021fad9565
BLAKE2b-256 76d633671d63a99c4f017481dc9167612e294dcc55b705e107ba151d2c9ef0d1

See more details on using hashes here.

Provenance

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page