Mongoqueue. Eine Warteschlange mit MONGO als Backend-Speicher
Jetzt downloaden

Mongoqueue. Ranking & Zusammenfassung

Mongoqueue. Stichworte

Warteschlange Python-Bibliothek Python Mongo.

Mongoqueue. Beschreibung

Mongoqueue ist eine Warteschlange mit MONGO als Backend Storage.Usagea-Warteschlange kann mit einer Mongo-Sammlung und einer Konsumkennung instanziiert werden. Die Konsumkennung dabei, mehrere Warteschlangenverbraucher zu unterscheiden, die Arbeitsplätze aus der Warteschlange einnehmen. >> von PyMongo Importverbindung >> von mongoqueue import mongoqueue >> warterue = mongoqueue (... Verbindung (test_db) .doctest_queue, ... consumer_id = "consumer-1", ... Timeout = 300, ... max_affen = 3) Die "Timeout-" -Stime` "-Stime`` `Der Parameter wird dauerhaft fehlgeschlagen und wird nicht mehr verarbeitet.NEw-Jobs / Artikel können in der Warteschlange platziert werden, indem ein Wörterbuch übergeben wird. >> warterue.put ({"foobar": 1}) Ein Job "Priority" -Taste "Priority" und Integer-Wert kann im Wörterbuch angegeben werden, was dazu führt, dass der zu verarbeitende Job, der vor niedrigeren Prioritätselemente verarbeitet werden soll. >> warterue.put ({"foobar": 0, "Priorität": 1}) Ein Element kann abgerufen werden, indem Sie das "Next`" -Methode in einer Warteschlange anrufen. Dies gibt ein Jobobjekt zurück. >> job = warteReue.next () >> job.data {"foobar": 1} Die Jobklasse stellt einige Steuerungsmethoden auf dem Job aus, um den Fortschritt, den Fertigstellung, Fehler zu markieren oder den Job wieder in die Warteschlange zu kennzeichnen. - `` complete` "markiert einen Job als vollständig und entfernt es aus der Warteschlange. - `` 'fehler'``' Optional mit einer Nachricht angegeben, veröffentlicht den Job wieder in die Warteschlange und erhöht seine Versuche und speichert die Fehlermeldung auf dem Job. - `` `« Fortschritt` `` Optional nimmt eine Fortschrittszählung integer, nimmt den Fortschritt auf dem Job an und setzt das Sperre-Timeout zurück. - `` `Release`` `Releben Sie einen Job zurück zum Pool. Der Zählerversuche ist nicht modifiziert >> Mit Job als Daten: ... Druckdaten {"Foobar: 0} Wenn der Kontextverschluss ausgerufen wird, ohne dass der Job abgeschlossen ist, wenn eine Ausnahme vorhanden ist, wird der Fehler auf der Homepage des Jobs gespeichert.

Mongoqueue. Zugehörige Software