芹菜检查指定taskid之前的未决任务数

Question

芹菜是否支持在给定任务 ID 之前返回挂起的任务编号？

例如，没有芹菜工人启动，我推task1、task2、task3，这三个都是挂起的，现在，我想要的是，如果我给task3，它告诉我在3之前有两个挂起的任务。

我使用芹菜芹菜4.1，rabbitmq 3.5.4作为代理，redis 3.2.9作为结果后端。

虽然我可以通过管理API（例如，从pyrabbit包中获取get_queue_depth）获得兔子队列深度，但这会导致整个队列深度，而不是指定任务ID之前的挂起数。

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

但是我想如果有什么简单的方法可以通过芹菜或Rabbitmq本身。

谢谢

Answer 1

我不确定它是否回答了您的问题，但有一个控制客户端可以帮助您检查保留的任务、活动的任务等等。。

i = app.control.inspect()
i.reserved()

#output:
[{'worker1.example.com':
    [{'name': 'tasks.sleeptask',
      'id': '32666e9b-809c-41fa-8e93-5ae0c80afbbf',
      'args': '(8,)',
      'kwargs': '{}'}]}]

欲了解更多信息： http://docs.celeryproject.org/en/latest/userguide/workers.html#dump-of-reserved-tasks

您还可以从命令行监视/检查：http://docs.celeryproject.org/en/latest/userguide/monitoring.html#commands