0
Ich versuche, einen einfachen AMQP-Client mit Python zu machen. Ich kopierte den Code, den ich in RabbitMQ Website:Leading b in Python Pika Antwort
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
Diese Ausnahme Es funktioniert immer druckt etwas wie [x] Received b'my Nachricht‘. Aus diesem Grund kann ich meine JSON-Nachrichten nicht parsen. Wie behebe ich das?
, die einfach war .. Danke –