Project Links

Meta

Author: Bogdan Popa

Requires Python: >=3.10

Classifiers

Programming Language

Python :: 3.10
Python :: 3.11
Python :: 3.12
Python :: 3.13
Python :: 3.14
Python :: 3 :: Only

Topic

System :: Distributed Computing

License

OSI Approved :: GNU Lesser General Public License v3 or later (LGPLv3+)

dramatiq

A fast and reliable distributed task processing library for Python 3.

Changelog: https://dramatiq.io/changelog.html
Community: https://groups.io/g/dramatiq-users
Documentation: https://dramatiq.io

Installation

If you want to use it with RabbitMQ

pip install 'dramatiq[rabbitmq, watch]'

or if you want to use it with Redis

pip install 'dramatiq[redis, watch]'

Quickstart

Make sure you've got RabbitMQ running, then create a new file called example.py:

import dramatiq
import requests
import sys


@dramatiq.actor
def count_words(url):
    response = requests.get(url)
    count = len(response.text.split(" "))
    print(f"There are {count} words at {url!r}.")


if __name__ == "__main__":
    count_words.send(sys.argv[1])

In one terminal, run your workers:

dramatiq example

In another, start enqueueing messages:

python example.py http://example.com
python example.py https://github.com
python example.py https://news.ycombinator.com

Check out the user guide to learn more!

License

dramatiq is licensed under the LGPL. Please see COPYING and COPYING.LESSER for licensing details.

Wheel compatibility matrix

Platform	Python 3
any

Files in release

dramatiq-2.1.0-py3-none-any.whl (122.6KiB)

dramatiq-2.1.0.tar.gz (103.0KiB)

Extras:

Dependencies:

dramatiq 2.1.0

Programming Language

Topic

License

dramatiq

Sponsors

Installation

Quickstart

License

Wheel compatibility matrix

Files in release