Пика - Как обработать исключение NoneTypes, когда начать потреблять

Question

Я пытаюсь проверить channel.consume при получении сообщения от сервера RabbitMQ с помощью Pika 0.11.2

Когда звоните get_mq и я обнаружил, что: исключение произошло, когда пустое сообщение в очереди. Итак, как я могу подтвердить исключение

Вот мой код:

def send_mq(self, message, queue_name):
    try:
        if message and queue_name:
            message = json.dumps(message)
            self.connect(queue_name)
            self.channel.basic_publish(exchange="", routing_key=queue_name, body=message)
            if self.mqConn:
                self.mqConn.close()
    except Exception as ex:
        sentry_log('send_mq_error', str(ex))

def get_mq(self, callback, queue_name, limit_message=0):
    if callback and queue_name:
        self.connect(queue_name)
        queue = self.channel.queue_declare(queue=queue_name, durable=True, exclusive=False, auto_delete=False)
        # Enabled delivery confirmations
        self.channel.confirm_delivery()
        if queue and queue.method.message_count > 0:
            # method_frame, header_frame, body = self.channel.basic_get(queue=queue_name)
            # self.channel.basic_ack(delivery_tag=method_frame.delivery_tag)
            # self.channel.basic_qos(prefetch_count=1)
            # self.channel.basic_consume(lambda ch, method, properties, body: callback(json.loads(body) if body else body), queue=queue_name, no_ack=True)
            # # # start consuming (blocks)
            # try:
            #     self.channel.start_consuming()
            # except KeyboardInterrupt:
            #     self.channel.stop_consuming()
            try:
                # Get ten messages and break out
                for method_frame, properties, body in self.channel.consume(queue=queue_name, inactivity_timeout=1):
                    if body:
                        # Acknowledge the message
                        self.channel.basic_ack(method_frame.delivery_tag)
                        self.channel.basic_qos(prefetch_count=1)

                        # Escape out of the loop with limit messages
                        if limit_message > 0 and method_frame.delivery_tag == limit_message:
                            break

                        callback(json.loads(body))
                    else:
                        break
                self.channel.cancel()
            except Exception as ex:
                self.channel.cancel()
                if self.mqConn:
                    self.mqConn.close()

Сообщение об ошибке:

Объект, не относящийся к типу, не повторяется

Answer 1

Команда RabbitMQ контролирует rabbitmq-users список рассылки и только иногда отвечает на вопросы по Stackru.

---

Здравствуйте, я один из сопровождающих Пика. consume Метод может вернуть 3-кортеж или None, так что вы должны обработать это, используя метод, представленный в этом комментарии.

Проблема была решена в этом запросе на получение и будет отправлена ​​в следующей версии Pika: https://github.com/pika/pika/pull/901