paho-mqtt+python3でメッセージをファイルに保存

Question

cloudMQTTを使い、paho-mqtt＆python3で端末をsubscribeさせ、受信したメッセージをテキストファイルに保存しようと考え、以下のプログラムを作成したのですが、ファイル保存ができません。具体的には、cloudMQTT側からメッセージを送っても、端末上では何も変化が無く、Connected to brokerと表示され、待ち状態のままです。（エラーも出ない）
on_messageの中でファイル保存をする場合、何か特別な処理等が必要なのでしょうか。　ちなみに、subscribeや、cloudMQTTから端末に対してのメッセージの送信は問題なく動作していましｔが、メッセージをファイル保存する為に、20〜23行目を追加したところ動作しなくなりました。

 1 import paho.mqtt.client as mqttClient
 2 import time
 3 import os
 4  
 5 def on_connect(client, userdata, flags, rc):
 6  
 7     if rc == 0:
 8  
 9         print("Connected to broker")
10  
11         global Connected                
12         Connected = True                
13  
14     else:
15  
16         print("Connection failed")
17  
18 def on_message(client, userdata, message):
19     print("Message received: "  + message.payload)
20     file = open('RX_message.txt','w')
21     string = ['新しいメッセージが届いています','\n\','受信内容:\n',message.payload]
22     file.writelines(string)
23     file.close()

Comments

[hayataka2049]

「できない」とはどのような状況でしょうか。エラー等が出るなら記載してください。

[hayataka2049]

「print("Message received: " + message.payload)」だけだと無事に受け取ったメッセージが表示されるが、20行以下を追加するとそれすらも出なくなるという認識で良いですか？

[sandalwalk]

ご理解の通りです。

[sandalwalk]

20行目以下を追加したことが問題では無いことが分かりました。python2.7で動作していたのですが、python3.5にするとcouldMQTTからメッセージを送っても"Connected to broker"の表示のまま、反応しない様です。

[hayataka2049]

pyhton2とpython3の仕様の違いや、ライブラリのバージョン違いなどが影響している可能性があるので、その線でデバッグしてみてください

Answer 1

動作環境をpython2.7->3.5に変更していたことが原因でした。python3.5用に以下の様に変更したところ動作しました。

18 def on_message(client, userdata, message):
19     msg = message.payload
20     print("Message received: ",msg.decode())
20     file = open('RX_message.txt','w')
21     string = ['新しいメッセージが届いています','\n\','受信内容:\n',msg.decode()]
22     file.writelines(string)
23     file.close()