有没有办法,如何检索使用 Redis 作为队列在芹菜中预取的任务的信息?
这些预取的任务就像幽灵一样。它们没有被处理,也没有在队列中等待,所以我对于 redis 它们是不可见的。
使用 rabbitMQ+celery,我可以看到所有任务(结合两者的 API(。但是使用 redis 时,我什么也看不到(实际上我只能计算队列中的任务 ->这是错误的,因为队列中的任务等于预取 + 排队(。芹菜的检查也没有帮助。
有没有一些简单的解决方案,redis在python中是否有一些不错的API,我可以通过它看到我的任务在哪里?
提前致谢
是的,有。检查 API 使您能够检查reserved
任务。它在 Celery 文档的命令部分中进行了介绍。类似于celery -A yourproj.app inspect registered
的东西应该为您提供每个工作人员的预取任务。如果在输出中看不到任何内容,则表示在该特定时刻没有保留任务。