# pip install paho-mqtt
import paho.mqtt.client as mqtt            # importando el objeto cliente

broker_address = "mosquito.tiburcio.mx"    # Dirección del broker
broker_port = 1883                         # Puerto del broker
topic = "notification"                     # Tópico a subscribirse

def on_message(client, userdata, message): # Función para desplegar tópico y mensaje 
   print("Topic=", message.topic) 
   print("Mensaje recibido=", str(message.payload.decode("utf-8")))

client = mqtt.Client("Subscriptor1")          # Creando instancia de cliente 
client.on_message = on_message                # Para mostrar mensajes del tópico 
client.connect(host=broker_address,port=1883) # Conecta al broker
client.subscribe(topic)                       # Subscripción al tópico
client.loop_forever()                         # Mantiene la subscripción iterando a la
                                              # espera de publicaciones. 
