muszę dodać trochę źle task do celery z REDiS brokerJak usunąć zadanie z selera z brokerem redis?
ale teraz chcę, aby usunąć niepoprawne task i nie mogę znaleźć żadnych sposób to zrobić
Czy istnieje niektóre polecenia lub niektóre API Zrób to ?
Znam dwa sposoby robienia tak:
1) skreśla kolejkę bezpośrednio z brokerem. W twoim przypadku jest to Redis. Istnieją dwie komendy, które mogą Ci pomóc: llen (aby znaleźć właściwą kolejkę) i del (aby ją usunąć).
2) Zacznij pracownika seler --purge lub --discard opcji. Oto help:
--purge, --discard Purges all waiting tasks before the daemon is started.
**WARNING**: This is unrecoverable, and the tasks will
be deleted from the messaging server.
th anki do powtórki, seler jest zbyt skomplikowany, zmieniłem mój projekt na python-rq – timger
To nie działa dla mnie. Reddis ma nadal całą kolejkę i nie mogę go usunąć. Seler kontynuuje przyjmowanie zadań –
prostu miałem ten problem, więc dla przyszłych czytelników,
tak, aby prawidłowo wyczyścić kolejkę zadań czekających trzeba zatrzymać wszystkie robotników, a następnie oczyść zadania za pomocą metody selery.control.purge().
1. Aby prawidłowo wyczyścić kolejkę oczekujących zadań trzeba zatrzymać wszystkich pracowników (http://celery.readthedocs.io/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue):
2 ... a potem oczyścić zadania z określonej kolejki:
$ cd <source_dir
$ celery amqp queue.purge <queue name>
3. zacząć od nowa
Zobacz, czy to pomoże: http://stackoverflow.com/questions/2557424/delete-task-periodictask-in-celery – alecxe