Shell Script to subscribe to MQTT and execute a callback

MQTTSubscribe.sh

#!/bin/bash

# This script subscribes to a MQTT topic using mosquitto_sub.
# On each message received, you can execute whatever you want.

while true  # Keep an infinite loop to reconnect when connection lost/broker unavailable
do
    mosquitto_sub -h "127.0.0.1" -t "test" | while read -r payload
    do
        # Here is the callback to execute whenever you receive a message:
        echo "Rx MQTT: ${payload}"
    done
    sleep 10  # Wait 10 seconds until reconnection
done # &  # Discomment the & to run in background (but you should rather run THIS script in background)

#!/bin/sh

# https://gist.github.com/David-Lor/63fb0be80b67359c8de6230c6b1dafa2

while true  # Keep an infinite loop to reconnect when connection lost/broker unavailable
do
    mosquitto_sub -h localhost -t zigbee2mqtt/things/\# -F "%t %p" | while read -r payload
    do
        # Here is the callback to execute whenever you receive a message:
        topic=$(echo "$payload" | cut -d ' ' -f 1)
        msg=$(echo "$payload" | cut -d ' ' -f 2-)
        echo "Rx MQTT: $topic: ${payload}"
        p=$(echo "$msg" | jq '.property')
        echo "Extracted property: $p for $topic"
    done
    sleep 10  # Wait 10 seconds until reconnection
done # &  # Discomment the & to run in background (but you should rather run THIS script in background)

Thank you for this script. Saved me a lot of time trying to figure out how to do this.

Thanks, that's a nice script to start with. Saved me a lot of time, too.

Smart script, very useful with "Docker Homeassistant" to interface with MQTT mosquitto on other machines (satellites for Rhasspy). Great teaching too ! Thanks a lot.