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 RabbitMQ
.
from flask import Flask
app = Flask(__name__)
app.config["MQ_URL"] = "<Your_MQ_URL>"
app.config["MQ_EXCHANGE"] = "<Your_MQ_Exchange_Name>"
amqp_service = RabbitMQ()
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.4.1.tar.gz
(20.7 kB
view hashes)
Built Distribution
Close
Hashes for amqpstorm_flask-0.4.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 35754eac35675f51a40407adce0ba1ed4166a2cdae830b954250e9b88015dcc2 |
|
MD5 | 240dfa36a2168b5ea1a9817dad8cb810 |
|
BLAKE2b-256 | 083dd25ca92c8e33162d8e250d5b314a0c1631565463c6bc795920fa2c9ab383 |