smarthome/mpd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Exception handling for MQTT

Browse Source
This commit is contained in:
Dirk Alders 2022-08-24 14:31:18 +01:00
parent 4ee21b692f
commit ee201df901
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
mpd_monitor.py
View File

@ -52,18 +52,25 @@ class mpc(object):
def send_state_msg_mqtt(state): def send_state_msg_mqtt(state):
client= paho.Client("mpd") client= paho.Client("mpd")
client.username_pw_set(config.MQTT_USER, config.MQTT_PASS) client.username_pw_set(config.MQTT_USER, config.MQTT_PASS)
client.connect(config.MQTT_SERVER, 1883) try:
topic = config.MQTT_TOPIC + "/state" client.connect(config.MQTT_SERVER, 1883)
logger.info("Sending MPD status information to mqtt %s = %s", topic, str(state)) topic = config.MQTT_TOPIC + "/state"
client.publish(topic, "true" if state else "false") logger.info("Sending MPD status information to mqtt %s = %s", topic, str(state))
client.publish(topic, "true" if state else "false")
except (socket.timeout, OSError) as e:
logger.warning("Erro while sending mpd state information")
def send_title_msg_mqtt(title): def send_title_msg_mqtt(title):
client= paho.Client("mpd") client= paho.Client("mpd")
client.username_pw_set(config.MQTT_USER, config.MQTT_PASS) client.username_pw_set(config.MQTT_USER, config.MQTT_PASS)
client.connect(config.MQTT_SERVER, 1883) try:
topic = config.MQTT_TOPIC + "/title" client.connect(config.MQTT_SERVER, 1883)
logger.info("Sending MPD title information to mqtt %s = \"%s\"", topic, title) topic = config.MQTT_TOPIC + "/title"
client.publish(topic, title) logger.info("Sending MPD title information to mqtt %s = \"%s\"", topic, title)
client.publish(topic, title)
except (socket.timeout, OSError) as e:
logger.warning("Erro while sending mpd title information")
if __name__ == '__main__': if __name__ == '__main__':