Background Processing for Python 3.
Project description
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.
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
remoulade-0.21.1.tar.gz
(72.2 kB
view hashes)
Built Distribution
remoulade-0.21.1-py3-none-any.whl
(118.4 kB
view hashes)
Close
Hashes for remoulade-0.21.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6350e956b14b176d29c2b43977e7444462e0c17570ac61fb96a5a39196b517e6 |
|
MD5 | 8b78fefcc92304c9026c6350b9aa53f2 |
|
BLAKE2b-256 | 136f7085075b9e1af317f0deb8e9bd18a94f782bad811881ffa8a9046b465f94 |