Соответствует ли сельдерей правильному тарифу?

Question

У меня есть задача с ограничением скорости в Сельдерей, но результаты, как показано в «Цвете», выглядят так, как будто они обрабатывают сразу несколько задач, а затем подчиняются пределу скорости. Почему это происходит? Есть ли что-то, что мне нужно сделать, чтобы убедиться, что он соблюдает ограничение скорости с самого начала?

@shared_task(rate_limit="4/m") 
    def my_task(a,b): 
     ... 

...

my_task.apply_async((x, y,),) 

Answer 1

У вас есть более чем один работник потребляющих my_task? Если так, ваш лимит ставок не будет введен в действие, поскольку лимиты скорости сельдерея равны на одного работника (docs). Чтобы обойти это, вам нужно направить my_task в очередь, в которой есть только один рабочий, потребляющий ее. См. routing docs.