celery

___ tag123python ___ Python ist eine dynamische und stark typisierte Programmiersprache, die die Usability betont. Zwei ähnliche, aber größtenteils inkompatible Versionen von Python sind weit verbreitet (2 und 3). Wenn Sie eine versionsspezifische Python-Frage haben, sollten Sie die Tags [python-2.7] oder [python-3.x] zusätzlich zum Tag [python] verwenden. Wenn Sie eine Python-Variante wie jython, pypy, iron-python usw. verwenden, kennzeichnen Sie diese bitte entsprechend. ___ tag123cellery ___ Sellery ist ein verteiltes Aufgabenwarteschlangen-Framework für Python, das für die asynchrone und parallele Ausführung verwendet wird. ___ qstnhdr ___ Sellerie Holen Sie sich die Liste der registrierten Aufgaben ___ qstntxt ___

Gibt es eine Möglichkeit, eine Liste der registrierten Aufgaben zu erhalten?

Ich habe es versucht:

%Vor%

Die nur eingebaute Sellerie Aufgaben wie Sellerie.chord, Sellerie.chain etc zurückgibt.

    
___ answer26211200 ___
%Vor%

Dies wird ein Wörterbuch aller Arbeiter & amp; verwandte registrierte Aufgaben.

%Vor%

Falls mehrere Worker dieselben Aufgaben ausführen oder wenn Sie nur eine Reihe aller registrierten Aufgaben benötigen, wird der Job ausgeführt.

Alternativer Weg:

Vom Terminal können Sie mit dem Befehl

einen Speicherauszug von registrierten Tasks erstellen %Vor%     
___
1
Antwort

Errno 111 Verbindung abgelehnt, wenn Sellerie mit SQS verwendet wird

Ich habe ein Problem, wenn ich die Befehle celery status oder celery purge ausführen. %Vor% Ich verwende SQS BROKER_URL. Die Aufgaben laufen gut, aber wenn ich die Aufgaben in einer Warteschlange ( celery purge -f ) löschen möchte, e...
04.07.2014, 00:09
2
Antworten

Verwenden mehrerer Installationen von Sellerie mit einem Redis Backend

Ist es möglich, dieselbe Redis-Datenbank für mehrere Projekte mit Sellerie zu verwenden? Zum Beispiel die Verwendung derselben Datenbank für mehrere Projekte als Cache unter Verwendung eines Schlüsselpräfixes. Oder muss ich für jede Installation...
21.08.2012, 09:39
4
Antworten

Django-Importschleife zwischen Sellerie-Aufgaben und meinen Modellen

Ich verwende Sellerie mit meinem Django-Projekt. In der Sellerie-Taskdatei muss ich meine Modelle importieren, um Modellmethoden auszulösen. Ich möchte aber auch, dass mein Modell bestimmte Sellerieaufgaben auslösen kann. Im Moment importi...
26.06.2013, 07:01
2
Antworten

Tierpflegerschloss blieb gesperrt

Ich benutze Sellerie und Tierpfleger (Kazoo-Sperre), um meine Arbeiter zu sperren. Ich habe ein Problem, wenn ich einen der Arbeiter töte (-9), bevor ich das Schloss loslasse, dann bleibt dieses Schloss für immer geschlossen. Meine Frage ist...
21.12.2012, 21:14
4
Antworten

Sellerie - minimieren Speicherverbrauch

Wir haben ~ 300 selleryd-Prozesse, die unter Ubuntu 10.4 64-bit laufen, im Leerlauf dauert jeder Prozess ~ 19mb RES, ~ 174mb VIRT, also - es sind etwa 6GB RAM im Leerlauf für alle Prozesse. Im aktiven Zustand - Prozess dauert bis zu 100 MB RES u...
03.12.2010, 14:08
1
Antwort

Sellerie: Standardmethode zum Abfragen ausstehender Aufgaben?

Gibt es eine Standard / Backend-unabhängige Methode zum Abfragen ausstehender Aufgaben basierend auf bestimmten Feldern? Ich habe zum Beispiel eine Aufgabe, die nach der "letzten Benutzerinteraktion" einmal ausgeführt werden muss, und ich möc...
09.08.2011, 15:05
1
Antwort

Erhalte den Fortschritt von der asynchronen Python-Sellerie-Kette durch die Ketten-ID

Ich versuche den Fortschritt einer Task-Kette zu erhalten, indem ich jeden Task-Status abfrage. Aber wenn ich die Kette durch ihre ID abrufe, bekomme ich ein Objekt, das sich anders verhält. In tasks.py %Vor% Beim Abfragen von ipython...
30.04.2013, 18:00
1
Antwort

Das Ergebnis des Selleriearbeiters wird ständig abgerufen

Ich habe eine Web-App, in der ich Sellerie verwenden möchte, um Hintergrundaufgaben aus einer Datenbank zu laden. Ich lade gerade die Datenbank auf Anfrage, möchte aber die Aufgaben stündlich laden und im Hintergrund arbeiten lassen. Ich benutze...
07.09.2016, 19:33
1
Antwort

Django Sellerie: Führe nur eine Instanz eines lang andauernden Prozesses aus

Ich habe einen lang andauernden Prozess, der alle fünf Minuten ausgeführt werden muss, aber mehr als eine Instanz der Prozesse sollte nie gleichzeitig ausgeführt werden. Der Prozess sollte normalerweise nicht länger als fünf Minuten dauern, aber...
17.01.2012, 23:10
1
Antwort

Sellerie: Korrekter Weg, um langwierige Initialisierungsfunktion (pro Prozess) auszuführen

TLDR; Um eine Initialisierungsfunktion für jeden von Sellerie erzeugten Prozess auszuführen, können Sie das Signal worker_process_init verwenden. Wie Sie in den Dokumenten nachlesen können, sollten Handler für dieses Signal dies nicht...
13.06.2014, 10:06