我有mqtt客戶端,它向broker發佈了一些消息。當mqtt客戶端和代理之間的連接丟失時,將json數據存儲在文件中
該消息是像下面
{
"message": {
"body": {
"software_sub_version": "O",
"software_version": 1.25,
"hardware_id": 17,
"machine_id": 39
},
"header": {
"Machine_name": "MY_MACHINE",
"message_type": "machine_data",
"message_version": "1.0",
"publish_time": "2017-02-22T06:44:27.281644+00:00"
}
}
}
在發佈消息時,我正在檢查是否有代理連接是有或沒有,如果它不存在,我存儲信息使用下面的代碼到文件。
def mqtt_publish():
if no_connection:
store_json_data()
else:
send_msg()
我還需要將存儲的味精一個一個地發送給經紀人。
while True:
if stored_msg_present:
send_stored_msg_to_broker()
什麼應該是最好的方法來做到這一點。 使用tinydb這樣的數據庫是否好用。 但我不能從tinydb數據庫中檢索元素。