0
0 комментариев

Почему при длительной задаче происходит дисконект с rabbitmq?

credentials = pika.PlainCredentials(rabbitmqConf['user'], rabbitmqConf['password'])
parameters = pika.ConnectionParameters(rabbitmqConf['host'], rabbitmqConf['port'], '/', credentials, socket_timeout=20)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare(queue=rabbitmqConf['queueName'], durable=True)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback, queue=rabbitmqConf['queueName'])
channel.start_consuming()

При выполнении длительной команды (~10 мин) и при вызове

ch.basic_ack(delivery_tag=method.delivery_tag)

pymongo выдает следующую ошибку

(-1, "ConnectionResetError(10054, 'Удаленный хост принудительно разорвал существующее подключение', None, 1005

Изменен статус публикации
Добавить комментарий