Skip to main content

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_consumer(
    queue_name="test_queue",
    routing_key="route.key",
)
def process_message(message):
    print(message.body)

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

amqpstorm_flask-0.0.4.tar.gz (19.6 kB view hashes)

Uploaded Source

Built Distribution

amqpstorm_flask-0.0.4-py3-none-any.whl (17.8 kB view hashes)

Uploaded Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page