dramatiq

dramatiq

Eine schnelle und zuverlässige Bibliothek zur verteilten Aufgabenverarbeitung für Python 3.

---

Änderungsprotokoll : https://dramatiq.io/changelog.html
Community : https://groups.io/g/dramatiq-users
Dokumentation : https://dramatiq.io

---

Sponsoren

Installation

Wenn Sie es mit RabbitMQ verwenden möchten

 pip install 'dramatiq[rabbitmq, watch]'

oder wenn Sie es mit Redis verwenden möchten

 pip install 'dramatiq[redis, watch]'

Schnellstart

Stellen Sie sicher, dass RabbitMQ ausgeführt wird, und erstellen Sie dann eine neue Datei mit dem Namen 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 ])

Führen Sie in einem Terminal Ihre Worker aus:

 dramatiq example

Beginnen Sie in einem anderen Fall damit, Nachrichten in die Warteschlange einzureihen:

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

Schauen Sie sich die Bedienungsanleitung an, um mehr zu erfahren!

Lizenz

dramatiq ist unter der LGPL lizenziert. Einzelheiten zur Lizenzierung finden Sie unter COPYING und COPYING.LESSER.