La librería Paho-Mqtt de Python usada que permite conectarse como cliente a MQTT.
Esto permite analizar los valores en los mensajes MQTT de los dispositivos para procesar, o activar algun proceso o evento con Python.
La conexión requiere los parámetros de dirección IP del servidor, puerto, datos de usuario, contraseña y el tópico.
# Parametros para la conexión servidormqtt = "192.168.xx.xx" usuario = "usuarioprueba" contrasena = "usuarioclave" topicolee = "#"
La instalación de la librería en Python se puede realizar con pip, tal como otras librerias en Python.
pip install paho-mqtt
Instrucciones en Python
# Conectando a MQTT-Mosquitto import paho.mqtt.client as mqtt # INGRESO # Parametros para la conexión servidormqtt = "192.168.xx.xx" usuario = "usuarioprueba" contrasena = "usuarioclave" topicolee = "#" # Funciones de conexión y mensaje # Al recibir CONNACK desde el servidor def on_connect(client, userdata, flags, rc): print("Conexión/código de resultado: "+str(rc)) # Inicio o renovación de subscripción client.subscribe(topicolee) # el tópico tiene una publicación def on_message(client, userdata, msg): print(msg.topic+" "+str(msg.payload)) unmensaje = msg.topic+" "+str(msg.payload) return() client = mqtt.Client() client.on_connect = on_connect client.on_message = on_message client.username_pw_set(username=usuario,password=contrasena) client.connect(servidormqtt, 1883, 60) client.loop_forever()
Referencia: paho-mqtt, https://pypi.org/project/paho-mqtt/#usage-and-api. https://pypi.org/project/paho-mqtt/#connect-reconnect-disconnect