Простая очередь с Celery и RabbitMQ - PullRequest
3 голосов
/ 11 ноября 2010

Я пытаюсь реализовать простую очередь, которая выполняет одну задачу за раз.Выгрузка задач из основного потока с помощью Celery и установка параллелизма = 1 в конфигурации Celery работает нормально, но я мог бы использовать больше параллельных рабочих для других задач.

Есть ли способ сказать Celery или RabbitMQ неиспользовать несколько параллельных рабочих для задачи (кроме принудительного параллелизма = 1)?Я ничего не могу найти в документации, но, может быть, эти инструменты не предназначены для линейной очереди?

Спасибо!

1 Ответ

0 голосов
/ 09 апреля 2011

Я думаю, что вам нужна отдельная очередь для каждого типа задач. Создайте отдельных рабочих, которые потребляют из каждой очереди, с параллелизмом, установленным в 1.

...