Als «celery» getaggte Fragen

Ich bin neu bei Nachrichtenbrokern wie RabbitMQ, mit denen wir Aufgaben / Nachrichtenwarteschlangen für ein Planungssystem wie Celery erstellen können . Hier ist die Frage: Ich kann in PostgreSQL eine Tabelle erstellen, die an neue Aufgaben angehängt und vom Verbraucherprogramm wie Celery verwendet...

Wie kann ich alle ausstehenden Aufgaben löschen, ohne die task_idfür jede Aufgabe zu

Wie kann ich eine Liste von Aufgaben in einer Warteschlange abrufen, die noch verarbeitet werden

In der Sellerie-Dokumentation wird das Testen von Sellerie in Django erwähnt , es wird jedoch nicht erläutert, wie eine Sellerie-Aufgabe getestet wird, wenn Sie Django nicht verwenden. Wie machst Du

Geschlossen . Diese Frage muss fokussierter sein . Derzeit werden keine Antworten akzeptiert. Möchten Sie diese Frage verbessern? Aktualisieren Sie die Frage so, dass sie sich nur auf ein Problem konzentriert, indem Sie diesen Beitrag bearbeiten . Geschlossen...

Ich versuche, ein Beispiel aus der Sellerie-Dokumentation auszuführen . Ich renne: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to...

Ich habe Probleme, den Zweck von "verteilten Aufgabenwarteschlangen" zu verstehen. Zum Beispiel die Selleriebibliothek von Python . Ich weiß, dass Sie in Sellerie, dem Python-Framework, zeitgesteuerte Fenster festlegen können, damit Funktionen ausgeführt werden. Dies kann jedoch auch problemlos in...

Ich habe das Dokument gelesen und gesucht, kann aber keine eindeutige Antwort finden: Können Sie eine bereits ausgeführte Aufgabe abbrechen? (Wie in der Aufgabe begonnen, dauert es eine Weile, und die Hälfte der Aufgabe muss abgebrochen werden) Ich fand dies aus dem Dokument bei Celery...

Wie prüft man, ob eine Aufgabe in Sellerie ausgeführt wird (insbesondere verwende ich Sellerie-Django)? Ich habe die Dokumentation gelesen und gegoogelt, kann aber keinen Anruf wie folgt sehen: my_example_task.state() == RUNNING Mein Anwendungsfall ist, dass ich einen externen (Java) Dienst zum...

Ich versuche, eine Testmethode für unser Django-Sellerie- Projekt zu entwickeln. Ich habe die Notizen in der Dokumentation gelesen , aber es gab mir keine gute Vorstellung davon, was ich tatsächlich tun sollte. Ich mache mir keine Sorgen um das Testen der Aufgaben in den eigentlichen Daemons,...

Ich habe gerade von der Konfigurationsoption CELERYD_PREFETCH_MULTIPLIER( docs ) erfahren . Der Standardwert ist 4, aber (glaube ich) ich möchte das Prefetching deaktivieren oder so niedrig wie möglich halten. Ich habe es jetzt auf 1 gesetzt, was nah genug an dem liegt, wonach ich suche, aber es...

Ich habe eine CPU-intensive Sellerie-Aufgabe. Ich möchte die gesamte Verarbeitungsleistung (Kerne) in vielen EC2-Instanzen nutzen, um diesen Job schneller zu erledigen (eine Sellerie-parallel verteilte Aufgabe mit Mehrfachverarbeitung - glaube ich ) . Die Begriffe Threading , Multiprocessing ,...

Wie kann ich den Wert task_id für eine Aufgabe aus der Aufgabe heraus abrufen? Hier ist mein Code: from celery.decorators import task from django.core.cache import cache @task def do_job(path): "Performs an operation on a file" # ... Code to perform the operation ... cache.set(current_task_id,...

Nach meinem Verständnis ist Sellerie eine verteilte Aufgabenwarteschlange. Dies bedeutet, dass nur Aufgaben / Jobs an andere Server gesendet und das Ergebnis zurückgegeben werden müssen. RabbitMQ ist eine Nachrichtenwarteschlange und nichts weiter. Ein Mitarbeiter kann jedoch einfach auf den MQ...

Ich benutze Sellerie und Django-Sellerie. Ich habe eine regelmäßige Aufgabe definiert, die ich testen möchte. Ist es möglich, die periodische Aufgabe manuell über die Shell auszuführen, damit ich die Konsolenausgabe anzeigen kann?

Angenommen, ich habe ein Modell Event. Ich möchte allen eingeladenen Benutzern nach Ablauf des Ereignisses eine Benachrichtigung (E-Mail, Push, was auch immer) senden. Etwas in der Art von: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited =...