An abstract interface for RabbitMQ communication
Project description
RabbitMQ without headache.
b-rabbit is a RabbitMq Interface on top of rabbitpy to make implementing RabbitMQ messaging patterns easier. It is very useful especially inside large projects, in which many boilerplate code must be written. it uses a parent wrapper class that wrap all connections and classes definitions of different messaging patterns, then using the patterns is pretty straightforward by creating instances from the parent class depending on the pattern you want to use. it uses multithreading to asynchronously orchestrate between multiple subscription and RPCs.
- Free software: MIT license
- Documentation: https://b-rabbit.readthedocs.io.
Features
- it implements all RabbitMQ messaging patterns.
- provides an easy high level API (take a look at the examples)
- thread safe since it uses rabbitpy
- implementation of the publish-subscribe pattern
- implementation of the Remote procedure call pattern
- safe message delivery
When you should use it
- if you are having problems with other non thread safe libraries (like I did)
- if you want to develop fast by using a high level API
- if you don’t want to write much code and save much time
- if you want to use multithreading
- if you want to get started with RabbitMQ
Why you should use it
- High level of abstraction
- Simple syntax and readability improvement
- Scalablity (since it uses multiple channels but only one connection)
- Asynchronous fast messaging
- Code reusability
Quick Usage
import the library:
from b_rabbit import BRabbit
create a parent instance which provide a global rabbitMQ connection
rabbit = BRabbit(host='localhost', port=5672)
now, just one liner to publish a message:
publisher = rabbit.EventPublisher(b_rabbit=rabbit, publisher_name='pub').publish(routing_key='testing.test', payload='Hello from publisher')
or if you want to subscribe and listen to a certain topic:
def callback(msg): # do something with the received msg from the publisher print(f"msg received: {msg}") # subscribe and run a listener in a thread subscriber = rabbit.EventSubscriber( b_rabbit=rabbit, routing_key='testing.test', publisher_name='pub', event_listener=callback).subscribe_on_thread()
Advanced Usage using RPC
- task requester
from b_rabbit import BRabbit def taskResponseListener(body): print('Task Response received') print(str(body)) rabbit = BRabbit(host='localhost', port=5672) taskRequesterSynchron = rabbit.TaskRequesterSynchron(b_rabbit=rabbit, executor_name='test', routing_key='testing.test', response_listener=taskResponseListener) taskRequesterSynchron.request_task('msg from requester') rabbit.close_connection()
- task responser (server)
from b_rabbit import BRabbit import time rabbit = BRabbit(host='localhost', port=5672) def taskListener(server, body): print('Task Request received') print(str(body)) time.sleep(5) server.send_return(payload="return this value to requester") taskExecuter = rabbit.TaskExecutor(b_rabbit=rabbit, executor_name='test', routing_key='testing.test', task_listener=taskListener).run_task_on_thread()
Further
Take a look in the examples folder for more. b_rabbit implements also the remote procedure call (RPC) pattern
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size b_rabbit-1.2.1-py2.py3-none-any.whl (8.5 kB) | File type Wheel | Python version py2.py3 | Upload date | Hashes View |
Filename, size b_rabbit-1.2.1.tar.gz (16.5 kB) | File type Source | Python version None | Upload date | Hashes View |
Hashes for b_rabbit-1.2.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | f4e291d555a11ae58f516e3923cd6df1db2e64604fa19d0c71007e1fe448cc92 |
|
MD5 | 2d6a4ed9d53ea96d40d0cccc31c082e1 |
|
BLAKE2-256 | ec93daf13dc55741a924bf8eaa8c2f5a0ae91fe899dc04e3d02ba593665768b5 |