main.py

import time

import paho.mqtt.client as mqtt
import logging.handlers

import config

logging.basicConfig(level=logging.DEBUG,
                    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')

logger = logging.getLogger()
logger.setLevel(logging.DEBUG)

# fh = logging.FileHandler('fl30door.log')
fh = logging.handlers.TimedRotatingFileHandler(filename='mqtt.log', when="midnight", backupCount=10)
fh.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))

fh.setLevel(logging.DEBUG)

logger.addHandler(fh)

# The callback for when the client receives a CONNACK response from the server.
def on_mqtt_connect(client, userdata, flags, rc):
    logger.info("Connected with result code "+str(rc))

    # Subscribing in on_connect() means that if we lose the connection and
    # reconnect then subscriptions will be renewed.
    client.subscribe("demo/#")


# The callback for when a PUBLISH message is received from the server.
def on_mqtt_message(client, userdata, msg):
    logger.debug(msg.topic+" "+str(msg.payload))
    if "demo/temp" == msg.topic:
        f = float(msg.payload.decode("utf-8") )
        print(f)


def main() -> None:
    """Run MQTT Client"""
    client = mqtt.Client()
    client.on_connect = on_mqtt_connect
    client.on_message = on_mqtt_message

    logger.info(f"Connecting to mqtt server {config.mqtt_host}:{config.mqtt_port}")
    client.connect(config.mqtt_host, config.mqtt_port, 60)

    client.loop_start()

    for i in range(0,10):
        client.publish("demo/test", f"Hello {i}".encode("utf-8"))
        time.sleep(1)


    time.sleep(5)
    logger.info("stopping mqtt client")
    client.loop_stop()


if __name__ == '__main__':
    main()