этой статьи https://habr.com/post/150134/ в rabbitMQ
и вобщем у меня как бы все норм но когда у меня длинная оброботка келбек функции)) у меня потом ошибка падает
'Connection reset by peer'
.
Как я понял это связанно с тем что rabbit ждет 30 секунд когда ему вернут ответ подтверждения что все норм .
time.sleep(random.randint(300, 400))
ch.basic_ack(delivery_tag=method.delivery_tag)
здесь я искуственно сделал задержку*
Вобщем вопрос в том как мне можно изменить с 30 секунд например на 300 секунд?
Я полазил по документации , но несмог сообразить.))
Код у меня по сути такой же как на хабре.
1. Есть ли причины, почему не селери? 2. А в селери при этой ошибке рекконект делают, похоже никак( Разве что немного асинхроности
у тебя проблема в Heartbeat. Кролик считает что клиент умер и обрывает соединение. Нельзя блокировать обработку heartbeat
Обсуждают сегодня