flask-dramatiq 0.8.0

Flask-Dramatiq plugs Dramatiq task queue in your Flask web application.

// Features //

• Configure Dramatiq from Flask configuration.
• Ensure Flask app is available to Dramatiq actor.
• Add worker command to Flask CLI.
• Enable Flask Application factory.
• Handle multiple brokers with configurable prefix.
• Integrates periodiq. Optionnal.

Full documentation at flask-dramatiq.readthedocs.io.

// Installation and Usage //

Flask-Dramatiq is licensed under BSD-3-Clause. Add flask-dramatiq to your project:

$ uv add flask-dramatiq

Then use Dramatiq object as a regular Flask extension:

from flask import Flask
from flask_dramatiq import Dramatiq

app = Flask(__name__)
dramatiq = Dramatiq(app)

@dramatiq.actor()
def my_actor():
    ...

@app.route("/")
def myhandler():
    my_actor.send()

Flask-Dramatiq adds two configuration keys:

• DRAMATIQ_BROKER, points to broker class like dramatiq.brokers.rabbitmq:RabbitmqBroker or dramatiq.brokers.redis:RedisBroker.
• DRAMATIQ_BROKER_URL is passed as url keyword argument to broker class.

Now run worker program to consume messages and execute tasks in the background:

$ flask worker --processes=1

A complete flask app is available in project source tree example.py.

// Credit and Support //

Feel free to open an issue or suggest a merge request on Github project page. Contribution welcome!

The project is based on Bogdanp/flask_dramatiq_example.