come rimuovere l'attività da sedano con il broker redis?

Question

ho aggiungere un po 'sbagliato task ad un celery con Redis broker

ma ora voglio rimuovere l'errata task e non riesco a trovare un modo per fare questo

v'è una certa comandi o qualche API per Fai questo ?

Answer 1

Conosco due modi di fare così:

1) Elimina coda direttamente dal broker. Nel tuo caso è Redis. Esistono due comandi che potrebbero essere d'aiuto: llen (per trovare la coda giusta) e del (per eliminarlo).

2) Iniziare lavoratore sedano con --purge o --discard opzioni. Qui è di aiuto:

--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. 

Answer 2

Ho appena avuto questo problema in modo per i lettori futuri,

http://celery.readthedocs.org/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue

modo per eliminare correttamente la coda di attività in attesa che dovete fermata tutti i lavoratori, quindi eliminare le attività utilizzando celery.control.purge().

Answer 3

1. Per eliminare correttamente la coda di attività in attesa si deve fermare tutti i lavoratori (http://celery.readthedocs.io/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue):

2 ... e poi eliminare i compiti da una specifica coda:

$ cd <source_dir 
$ celery amqp queue.purge <queue name> 

lavoratori

3. ricominciare