2016-03-21 2 views
0

私はPythonを使って簡単なAMQPクライアントを作ろうとしています。これは、それ以外に動作python pikaのレスポンスをリードする

#!/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() 

は常に[X] b'myメッセージ」を受信したようなものを出力します。私はRabbitMQのウェブサイトで見つけたコードをコピーしました。このため私はjsonのメッセージを解析できません。これをどうやって解決するのですか?

答えて

3

あなたはUTF-8に文字列を変換し、それをプリントアウトし、簡単だった

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

のようなものするために)(デコードを使用することができます。..感謝 –

関連する問題