在系统级别控制每个任务队列的并发性

Question

问题

我想在系统级别（跨所有 celery worker）控制队列“foo”的最大并发性。我使用 Redis 作为代理，我所有的工作人员（包括节拍）都在 Windows 计算机上。另一种说法是，我想在 REDIS QUEUE 级别而不是单个 celery worker 级别控制活动任务。

有没有内置的方法来做到这一点？

我有：

1. 通过 Celery 文档搜索（确实缺少...）
2. 尝试使用聊天 GPT

变通实施

我目前能想到的唯一解决实现的方法是拥有一个 CRON 作业，如果所有工作人员的活动任务数小于队列的最大并发数，它只会将任务添加到我的队列中。 （基本上 -

app.control.inspect().active()

）。

谢谢。