Потоковое соединение потеряно: AssertionError (('_ AsyncTransportBase._produce () tx размер буфера недопустим', -275, 1),) - PullRequest
Новая
       16

Потоковое соединение потеряно: AssertionError (('_ AsyncTransportBase._produce () tx размер буфера недопустим', -275, 1),)

0 голосов
/ 27 марта 2020

Эта ошибка возникает при публикации большого числа запросов

ошибка: Потоковое соединение потеряно: AssertionError (('_ AsyncTransportBase._produce () tx, размер буфера недопустимый', -275, 1),) 

@name_space.route('/gravar-coleta-lista-hoteis')
class GravarColetaListaHoteis(Resource):
    def post(self):
        try:
            data = request.get_json()
            rabbitMQProducerService.publish(data, QueueNameConst.queue_name_hotel)
            return "ok"

class RabbitMQProducerService:
connection = None
channel = None
persistence_dao_mongo = None
rabbitmq_host = None
credentials = None

def __init__(self, rabbitmq_host, rabbitmq_user, rabbitmq_password):
    self.rabbitmq_host = rabbitmq_host
    self.credentials = pika.PlainCredentials(rabbitmq_user, rabbitmq_password)
    self.connect()

def publish(self, body, queue_name):
    if self.channel.is_closed:
        self.connect()
    self.channel.basic_publish(exchange='',
                               routing_key=queue_name,
                               body=json.dumps(body))

def connect(self):
    self.connection = pika.BlockingConnection(pika.ConnectionParameters(
        host=self.rabbitmq_host,
        credentials=self.credentials))
    self.channel = self.connection.channel()
...