remoulade 0.19.0

Background Processing for Python 3.

remoulade

A fast and reliable distributed task processing library for Python 3. Fork of dramatiq.io

---

Changelog: https://remoulade.readthedocs.io/en/latest/changelog.html
Documentation: https://remoulade.readthedocs.io

---

Installation

If you want to use it with RabbitMQ

pipenv install 'remoulade[rabbitmq, watch]'

or if you want to use it with Redis

pipenv install 'remoulade[redis, watch]'

Quickstart

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

import remoulade
import requests
import sys

@remoulade.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:

remoulade 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

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