Ich habe ein Problem, wenn ich die Befehle celery status oder celery purge ausführen.
Ich verwende SQS BROKER_URL.
Die Aufgaben laufen gut, aber wenn ich die Aufgaben in einer Warteschlange ( celery purge -f ) löschen möchte, erhalte ich den obigen Fehler.
Mein Server hat Ports 22, 80, 443, 8000 Ports geöffnet und es gibt Unmengen von Nachrichten in der Warteschlange SQS celery , so dass die Verbindung zwischen Sellerie und SQS in Ordnung sein sollte.
Basierend auf Dokumentation des Befehls status und clean müssen Sie Sellerie bereitstellen die Sellerie-App, auf die du dich beziehst, damit sie weiß, welcher Broker benutzt werden soll. Geben Sie einfach $celery purge ein oder geben Sie% co_de ein.% Sellery weiß nicht, auf welche Sellerie-App Sie abzielen und schlägt daher fehl.
Gehen Sie deshalb zu Ihrer Sellerie-App
$celery status
und dann rufen Sie Sellerie Purge in Ihrer App. In diesem Beispiel hat mein Verzeichnis $cd /path/to/your/celery/app/directory und der Inhalt lautet:
Der Inhalt ist nicht so wichtig wie unser Anruf, aber er zeigt an, dass wir unsere Sellerie-App in celeryapp.py haben, damit ich
oder
%Vor%Ich hatte eine ähnliche Frage hier und Sol schien zu bestätigen, dass Sellerie ausgegeben wird Dieser Fehler tritt auf, wenn keine App durch Angabe von
bereitgestellt wirdWie würde es wissen, welchen Broker-Transport man verwenden soll, wenn man nicht den Ort der App angibt?
Tags und Links django celery amazon-sqs