Блог

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

Вот что я делаю.

 def get_connection_channel(self):
    if self.channel is None:
        self.logger.info("Creating MQ connection channel on local host")
        self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
        self.channel = self.connection.channel()
        self.logger.info("Channel created")
    return self.channel

def close_connection_channel(self):
    self.channel.close()
    self.connection.close()
 

Я новичок, пытаюсь отточить свои навыки.