распределение сельдерея по потребителю

Question

вот небольшой фон для моего вопроса.
У нас есть конвертер, который преобразует XML в вызовы API.
У нас много клиентов, конвертирующих XML, и теперь некоторым клиентам приходится ждать, пока клиентзакончил преобразование сотен XML-файлов.
у нас есть сельдерей, работающий с rabbitmq

, чего я пытаюсь достичь:
назначить всех работников сельдерея одному клиенту, пока другой клиент не отправит XML-файлы, если есть другойклиент в очереди назначает половину сельдерея другому клиенту.

Может ли кто-нибудь указать мне правильное направление, я не могу понять, с чего начать.Извините за мои странные предложения английский не мой родной язык.

Answer 1

О том, чего вы пытаетесь достичь - я думаю, слишком сложно для Сельдерея.

Очевидный ответ - увеличить число работников Celery, используя опцию concurrency при запуске работника. Это легко сделать, и вам не нужно менять код. Я бы порекомендовал это.

Еще один вариант, который не так прост, но может оказаться прекрасным решением, - это использовать отдельный виртуальный хост RabbiMQ для каждого клиента. Я не могу сказать вам, как сделать это полностью в этом случае, но это может стать вашей отправной точкой.