Максимальная длина очереди обмена RabbitMQ

Я пытаюсь применить некоторое управление потоком в своем приложении, основанном на RabbitMQ.

Очень краткий обзор моей системы:

• Есть несколько синих рабочих, которые сканируют и вводят каталог и публикуют сообщения на обмен.
• Есть и другие ред-воркеры, которые потребляют из этого обмена (на основе ключей маршрутизации) и делают с данными все, что они делают, а затем удаляют их.

Данные, которые «хранятся» на бирже, довольно велики, и время, которое требуется рабочему для их обработки, заметно. Через некоторое время я получаю предупреждение о памяти от RabbitMQ, в котором говорится, что использование памяти слишком велико, и все операции публикации остановлены.

Я попытался увеличить объем памяти, который использует Rabbitmq, но это просто отложило проблему на несколько часов (время выполнения). Я также сделал очереди дисковыми, а не оперативными, но вместо этого мой диск был заполнен.

Поскольку мой ввод не такой большой, я могу жить с «большой» очередью ввода, из которой синие рабочие считывают свой ввод. Вот я и подумал попробовать установить некую "максимальную длину" на линк между синими рабочими и биржей. Я думаю, что ничего не потеряю здесь, так как реальным узким местом моей системы являются редворкеры (кстати я задекларировал связь между редворкерами и обменом с prefech_count=2).

После всего этого... Мне не удалось применить такую ​​максимальную длину :( Я использую Pika для объявления своих очередей и работы с каналами. Я прочитал это (https://www.rabbitmq.com/maxlength.html), но не смог реализовать его в своем коде, и я хотел бы увидеть пример, в котором используется этот флаг максимального размера.