python - 如何使用 redis 代理从 celery 中删除任务?

标签 python celery celery-task celeryd

我用 redis broker 添加了一些错误的 taskcelery

但现在我想删除不正确的任务,但我找不到任何方法来做到这一点

是否有一些命令或一些 api 可以执行此操作?

最佳答案

我知道有两种方法:

1) 直接从代理删除队列。在您的情况下,它是 Redis。有两个命令可以帮助您:llen (找到正确的队列)和 del (删除它)。

2) 使用--purge--discard 选项启动celery worker。这是帮助:

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

关于python - 如何使用 redis 代理从 celery 中删除任务?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17184244/

相关文章:

python - Celery-Django 作为守护进程 : Settings not found

python - Django DatabaseError - 没有这样的保存点

celery - 如何在内存中加载对象并在 Celery worker 的不同执行之间共享?

python - Django ORM,如何使用 values() 并仍然使用 choicefield?

python - Celery 分配队列和工作人员

python 和 pandas - 如何使用 iterrows 访问列

python - 无法启动 Celery Worker (Kombu.asynchronous.timer)

python - 从 Celery 中的 taskset_id 检索 GroupResult?

python - 有没有办法更有效地遍历 pandas 数据框中的行?

python - gspread 在谷歌电子表格上写入数据在实时数据库上出现错误