diff --git a/omv_backup_v2.py b/omv_backup_v2.py index 8116ffb..3e02065 100644 --- a/omv_backup_v2.py +++ b/omv_backup_v2.py @@ -315,7 +315,7 @@ if _BACKUP: now = datetime.datetime.now() STARTTIME = now.strftime("%Y-%m-%d_%H:%M:%S") msg = {"mode":_MODE, "status":"started","bak_name":"complete","host":"","cur_job":"","start_time":STARTTIME,"end_time":"in progress","progress":0,"finished":",".join(finished)} - client.publish(topic_sum, json.dumps(msg),2,True); + client.publish(topic_sum, json.dumps(msg),qos=0, retain=True); client.disconnect() # iterate over files in # that directory @@ -333,7 +333,7 @@ if _BACKUP: client.connect(broker,1883,60) msg = {"status":"inactive","bak_name":b,"start_time":"inactive","end_time":"inactive","progress":0} - client.publish(topic, json.dumps(msg)) + client.publish(topic, json.dumps(msg),qos=0, retain=True) client.disconnect() continue @@ -356,7 +356,7 @@ if _BACKUP: # msg = {"status":"started","bak_name":b,"start_time":DATETIME,"end_time":"in progress", "progress":0} msg = {"mode":_MODE, "status":"started","bak_name":"complete","host":host,"cur_job":b,"start_time":STARTTIME,"end_time":"in progress","progress":0,"finished":",".join(finished)} client.connect(broker,1883,60) - client.publish(topic, json.dumps(msg),2,True) + client.publish(topic, json.dumps(msg),qos=0, retain=True) client.disconnect() cmnd = "mkdir -p " + NEW_BACKUP_DIR @@ -425,7 +425,7 @@ if _BACKUP: finished.append(b) msg = {"mode":_MODE, "status":"finished","bak_name":"complete","host":host,"cur_job":b,"start_time":ENDTIME,"end_time":"in progress","progress":0,"finished":",".join(finished)} client.connect(broker,1883,10) - client.publish(topic, json.dumps(msg),2,True) + client.publish(topic, json.dumps(msg),qos=0, retain=True) client.disconnect() print("Getting size of FS") @@ -443,7 +443,7 @@ if _BACKUP: client.connect(broker,1883,10) - client.publish(topic_sum, json.dumps(msg),2,True) + client.publish(topic_sum, json.dumps(msg),qos=0, retain=True) client.disconnect() os.remove(filename.path)