小编Sto*_*orm的帖子

Celery 在指定 taskid 之前检查待处理的任务数

celery 是否支持在给定任务 id 之前返回待处理的任务编号?

例如,没有 celery worker 启动,我推送 task1、task2、task3,三个都挂了,现在,我想要的是,如果我给 task3,它告诉我在 3 之前有 2 个挂起的任务。

我使用 celery celery 4.1,rabbitmq 3.5.4 作为代理,redis 3.2.9 作为结果后端。

虽然我可以通过管理 API(例如 pyrabbit 包中的 get_queue_depth )获取兔子队列深度,但这会导致整个队列深度,而不是指定任务 id 之前的待处理数。

而且我知道我可以自己维护一个队列来管理推送的任务 ID。

但我想知道芹菜或rabbitmq本身是否有任何简单的方法。

谢谢。

python rabbitmq celery

5
推荐指数
1
解决办法
431
查看次数

标签 统计

celery ×1

python ×1

rabbitmq ×1