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.2.tar.gz
(20.3 kB
view hashes)
Built Distribution
Close
Hashes for amqpstorm_flask-0.1.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e8c4ec87f74c4774846439a622b63043843777ae05aef70eda5b0ee3fd8eec60 |
|
MD5 | 0f23eeedc0326b4e7ea078c27871882b |
|
BLAKE2b-256 | 53152f36a0e6ded33c15b2f0fcab90c42e8f6f7a95aa3f32120657b5aed6265f |