我可以检查并逐个删除芹菜/ RabbitMQ的任务是什么?(Can I review and del

2019-09-26 23:39发布

我正在运行的Django +芹菜+ RabbitMQ的。 修改一些任务名称后,我开始变得“​​未注册的任务” KeyErrors,即使从周期性任务表在Django芹菜此键删除任务,击败并重新启动芹菜工人之后。

事实证明, 芹菜/ RabbitMQ的任务是持久的 。 我最终被解决了问题重新实现遗留任务作为虚拟方法 。

今后,我宁愿不清除队列,重新启动工人或重新实现传统方法。 相反,我想检查队列,并逐个删除任何遗留的任务。 这可能吗? (优选地,在Django管理接口的上下文中)。

Answer 1:

芹菜inspect可以帮助

到查看活动队列:

celery -A proj inspect active_queues

要终止一个进程:

celery -A proj control invoke process_id

要查看所有availble的检查选项:

celery inspect --help


文章来源: Can I review and delete Celery / RabbitMQ tasks individually?