amqpstorm library for Flask
Project description
AMQP Service for Flask Apps
Features
- Connection validation and reconnection for AMQP.
- Sending messages to a specified exchange with retries.
- Consuming messages from a queue with retries.
- Customizable parameters for exchanges and queues.
- Message headers and properties support.
- Multi-threading support for consumers.
Prerequisites
- Python 3.x
- Flask
- amqpstorm
- retry
Installation
To install the required dependencies, run:
pip install amqpstorm-flask
Usage
Initialization
First, create a Flask app and initialize the AmqpService
.
from flask import Flask
app = Flask(__name__)
app.config["MQ_URL"] = "<Your_MQ_URL>"
app.config["MQ_EXCHANGE"] = "<Your_MQ_Exchange_Name>"
amqp_service = AmqpService()
amqp_service.init_app(app)
Sending Messages
To send a message to a specified exchange:
amqp_service.send(
body={"key": "value"},
routing_key="route.key",
exchange_type="direct",
retries=5,
)
Consuming Messages
To consume messages from a specified queue:
@amqp_service.queue(
queue_name="test_queue",
routing_key="route.key",
)
def process_message(message):
print(message.body)
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.
Source Distribution
amqpstorm_flask-0.1.1.tar.gz
(20.3 kB
view hashes)
Built Distribution
Close
Hashes for amqpstorm_flask-0.1.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1229fa2aa06ec9505628246244849d379d612b20e388eac446e40d4b9bfab3cc |
|
MD5 | 9b5e6f5c48c37686b69e5ae25f60be22 |
|
BLAKE2b-256 | 68c937f3e85a76ab513e79fa12bb98377e04ff1a7d1f17e980603b1d0bb4444b |