如何使用redis broker从芹菜中删除任务？

我有添加一些错误task到celery与Redis的broker如何使用redis broker从芹菜中删除任务？

，但现在我想删除不正确的task，我无法找到任何方式做到这一点

有一些命令或某些API来做这个？

来源

2013-06-19 timger

看它是否会有所帮助：http://stackoverflow.com/questions/2557424/delete-task-periodictask-in-celery – alecxe

我知道这样做的方法有两种：

1）直接从代理删除队列。你的情况是Redis。有两个命令，可以帮助你：LLEN（找到合适的队列）和德尔（将其删除）。

2）启动芹菜工- 冲洗或--discard选项。下面是帮助：

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

来源

2013-06-22 12:07:57

日重复播放，芹菜太复杂，我已经将我的项目更改为python-rq – timger

它对我不起作用。 Reddis仍然排队，我无法删除它。芹菜继续接受任务 –

我只是有这个问题，所以对于未来的读者，

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

所以正确清洗你有等待任务的队列停止所有工人，然后使用celery.control.purge（）清除任务。

来源

2015-07-01 00:23:14 straykiwi

1. 要正确地清除的，你必须停止所有的工人正在等待的任务队列（http://celery.readthedocs.io/en/latest/faq.html#i-ve-purged-messages-but-there-are-still-messages-left-in-the-queue）：

2 ...，然后从特定队列清除任务：

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

3. 启动职工再

来源

2017-03-27 15:28:55 ukr

如何使用redis broker从芹菜中删除任务？

回答

相关问题