dramatiq

dramatiq

Une bibliothèque de traitement de tâches distribuée rapide et fiable pour Python 3.

---

Journal des modifications : https://dramatiq.io/changelog.html
Communauté : https://groups.io/g/dramatiq-users
Documentation : https://dramatiq.io

---

Commanditaires

Installation

Si vous souhaitez l'utiliser avec RabbitMQ

 pip install 'dramatiq[rabbitmq, watch]'

ou si vous souhaitez l'utiliser avec Redis

 pip install 'dramatiq[redis, watch]'

Démarrage rapide

Assurez-vous que RabbitMQ est en cours d'exécution, puis créez un nouveau fichier appelé 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 ])

Dans un seul terminal, exécutez vos travailleurs :

 dramatiq example

Dans un autre, commencez à mettre les messages en file d'attente :

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

Consultez le guide de l'utilisateur pour en savoir plus !

Licence

dramatiq est sous licence LGPL. Veuillez consulter COPYING et COPYING.LESSER pour plus de détails sur la licence.