2016-03-21 6 views
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?

Antwort

3

können Sie verwenden decode() die Zeichenfolge zu konvertieren, um UTF-8 und es dann aus drucken, so etwas wie

str = 'your str' 
print(str.decode()) 
+0

, die einfach war .. Danke –