Contains the python scripts I use to interact with a Mqtt server. There is a publisher one and a subscriptor one. All the configuration parameters are in the configuration.py file.

• Broker = '192.168.1.11'

Basically the ip address or the name of your Mqtt broker. If your are playing around with a HAServer (probably with the Mosquito broker) it's the ip address of the server it's self.

• UserName = 'mqtt'

The username used to connect to the Mqtt broker. If your are playing around with a HAServer it can be any of the users that have access to the HA Server (it can be a good idea to use the same one you configured while setting up the Mosquito Mqtt broker in HAServer).

• Password = 'mqtt'

The password for the username

• Topic = "display/state"

The topic under which is going to be published the messages in our Mqtt broker. In my case it's part of a bigger project.

• Port = 1883
• ClientId = f'python-mqtt-pub-{randint(0, 1000)}' # Just some value in order to appear in the logs
• RetryConnectionTime = 5
• PublishRepetitionTime = 10

It's not really necessary to configure any of this parameters, and their names have to be clear enough in order to know what are the used to. Just one to consider: WaitForLoopTime, dont try to push it to 0, it seems stupid but it takes sometime to construcs the loop and it's the best option I found in order to wait for it.

python .\publish.py
[2024-01-18 08:05:19,854] DEBUG    publish.py   main(): Logging active for me: publish.py
[2024-01-18 08:05:19,914] INFO     publish.py   OnConnect(): Succesfully connected to Mqtt broker
[2024-01-18 08:05:20,885] DEBUG    publish.py   publish(): Dictionary={'Element': 'WifiSolar', 'Status': 2}
[2024-01-18 08:05:20,887] INFO     publish.py   publish(): Send {"Element": "WifiSolar", "Status": 2} to topic {display/state}
[2024-01-18 08:05:20,888] DEBUG    publish.py   main(): For ever loop, sleeping 10
[2024-01-18 08:05:30,889] DEBUG    publish.py   publish(): Dictionary={'Element': 'WifiSolar', 'Status': 2}
[2024-01-18 08:05:30,889] INFO     publish.py   publish(): Send {"Element": "WifiSolar", "Status": 2} to topic {display/state}
[2024-01-18 08:05:30,890] DEBUG    publish.py   main(): For ever loop, sleeping 10
(...)

It just subscribe to the topic we specify in the config and gets the dictionary object that is passed as a json. Nothing else.

python .\subscribe.py
[2024-01-18 08:12:19,183] DEBUG    subscribe.py main: Logging active for me: subscribe.py
[2024-01-18 08:12:19,207] INFO     subscribe.py OnConnect(): Succesfully connected to Mqtt broker
[2024-01-18 08:12:26,007] INFO     subscribe.py OnMessage(): Received {"Element": "WifiSolar", "Status": 0} from topic {display/state}
[2024-01-18 08:12:26,007] DEBUG    subscribe.py OnMessage(): Dictionary={'Element': 'WifiSolar', 'Status': 0}
[2024-01-18 08:12:36,005] INFO     subscribe.py OnMessage(): Received {"Element": "WifiSolar", "Status": 1} from topic {display/state}
[2024-01-18 08:12:36,005] DEBUG    subscribe.py OnMessage(): Dictionary={'Element': 'WifiSolar', 'Status': 1}

I want to try to learn some PySimpleGUI so I made a gui interface for the subscribe. It has something special, as we are building parts of a bigger project, we used to send allways this kind of json object

MessageDict = {
                'Element': 'WifiSolar',
                'Status': randint(0, 2)
            }

In this GUI we are going to generate and image with the name of the Element, and green if Status is 0 or red if status is 1 , or question mark if status is other. It doesnt have any sense for you? sure. Let me finish the big project and every thing will go with sense.

Mqtt explorer is a very good option in order to be able to see in real time how our messages are being stored in Mqtt. Thanks to Thomas Nordquist!

https://github.com/thomasnordquist/MQTT-Explorer