RabbitMQ app framework
Project description
RabbitBus
Feel RabbitMQ like HTTP
- Custom CorrelationManagers
- Regexp routes
Installation
RabbitBus requires Python 3.6 >, aioamqp.
Install the dependencies and library.
$ pip install rabbitbus
Example:
import asyncio
from rabbitbus.manager import DatabusApp, Configuration
from rabbitbus.acks.requests import AmqpRequest
from rabbitbus.acks.responses import AckResponse
async def my_view(request: AmqpRequest):
# Write your code here
return AckResponse(request)
def serve():
loop = asyncio.get_event_loop()
# Inherit from CorrelationManager for custom correlation storages
app = DatabusApp(conf=Configuration())
app.add_route(r'^CASH_REGISTER_EQUIPMENTS[a-zA-Z_]{4}$', my_view)
app.start(loop)
if __name__ == '__main__':
serve()
If message has reply_to property, you can make response like
from rabbitbus.acks.requests import AmqpRequest
from rabbitbus.acks.responses import AckResponse
async def my_view(request: AmqpRequest):
# Write your code here
return AckResponse(request, data={"result": 1})
"reply_to" will be converted to the "routing_key" and message will be published to the app exchange. More about RPC you can read in RabbitMQ documentation
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
rabbitbus-0.1.1.tar.gz
(6.4 kB
view hashes)