2

Идет обработка сообщений из очереди по такой схеме:

q_connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        host='127.0.0.1',
        virtual_host='/',
        credentials=pika.PlainCredentials(
            username='user',
            password='password'
        )
    )
)

channel = q_connection.channel()
channel.queue_declare(
    queue='processing',
    passive=False,
    durable=True,
    exclusive=False,
    auto_delete=False
)
channel.exchange_declare(exchange='router', type='direct', passive=False, durable=True, auto_delete=False)
channel.queue_bind('processing', 'router')

def callback(ch, method, properties, body):
    # действия над полученными сообщениями
    ...

    ch.basic_ack(delivery_tag=method.delivery_tag) # а вот тут периодически вылетает ошибка

channel.basic_consume(
    callback,
    queue='processing'
)
channel.start_consuming()

периодически возникает ошибка: The AMQP connection was closed: () при вызове метода basic_ack в callback.

Предполагаю, что действия над сообщениями занимают достаточно долгое время, чтобы потерять коннект.

Каким образом можно увеличить время тайм-аута, или как сделать реконнект в случае получения исключения?

1 ответ 1

0

Чтобы автоматически восстанавливать коннект необходимо реализовать асинхронный consumer https://pika.readthedocs.io/en/latest/examples/asynchronous_consumer_example.html

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.