了解基本 celery 消息队列的工作原理

Question

我已经实现了一个使用 celery 进行消息队列的小测试，我只是想确保我了解它在基本级别上的工作原理（Django-Celery，使用 Redis 作为代理）。

我的理解是，当我调用启动异步任务时，任务信息放在redis中，然后连接到broker的celeryd实例消费并执行任务。这基本上是正在发生的事情吗？

如果我设置了一个应该每小时执行一次的周期性任务，该任务会在所有任务使用者上执行吗？如果是这样，有没有办法限制它，以便只有一个消费者会执行周期性任务？

Answer 1

workers 将使用代理所包含的尽可能多的消息。如果您有 8 个工作人员，但只有 1 条消息，则 8 个工作人员中的 1 个将使用该消息，执行任务。