mirror of
https://gitlab.sectorq.eu/jaydee/omv_backup.git
synced 2025-09-13 12:10:12 +02:00
build
This commit is contained in:
@@ -199,11 +199,12 @@ hm = socket.gethostbyaddr(BACKUP_HOST)
|
|||||||
|
|
||||||
logging.info(_RESTORE)
|
logging.info(_RESTORE)
|
||||||
def send_mqtt_message(topic,msg):
|
def send_mqtt_message(topic,msg):
|
||||||
global client
|
client2 = mqtt.Client()
|
||||||
|
client2.username_pw_set(USERNAME, PASSWORD)
|
||||||
try:
|
try:
|
||||||
#client.connect(broker,1883,60)
|
client2.connect(broker,1883,60)
|
||||||
client.publish(topic, json.dumps(msg))
|
client2.publish(topic, json.dumps(msg))
|
||||||
#client.disconnect()
|
client2.disconnect()
|
||||||
logging.info(f"Message sent {topic}, {msg}")
|
logging.info(f"Message sent {topic}, {msg}")
|
||||||
except ValueError as e:
|
except ValueError as e:
|
||||||
logging.error("Failed to send")
|
logging.error("Failed to send")
|
||||||
|
Reference in New Issue
Block a user