Найти - Пользователи
Полная версия: rabbitmq blocking connection перестает слушать очередь на долгих тасках
Начало » Python для экспертов » rabbitmq blocking connection перестает слушать очередь на долгих тасках
1
xz_kto
Привет.
Есть rabbitmq, очерь, продьюсер и косньюмер.

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

Таски делаются 2-3 минуты, пробовал heartbeat крутить: выключать, ставить большой(не помогло), пробовал делать sleep в connection в 500 секунд, не помогло.

Были ли у вас подобные проблемы?
Буду рад советам
JOHN_16
вы используете celery?
Долгие такси это по времени сколько?
xz_kto
JOHN_16
вы используете celery?Долгие такси это по времени сколько?
celery не использую. Просто получаю сообщения из очереди и процесю файлы.
Долгие таски это 2-3 минуты. Видимо для рэбита это долго.
DamMercul
Используй неблокирующую очередь и тести на try-except'е в цикле.
This is a "lo-fi" version of our main content. To view the full version with more information, formatting and images, please click here.
Powered by DjangoBB