mxtt_paho module

class mxtt_paho.MQTTClient(url, port, username, password, use_tls=False)

Bases: QThread

Cliente MQTT ejecutado en un hilo independiente usando QThread.

  • Maneja la conexión a un broker MQTT (con soporte TLS).

  • Permite publicar y suscribirse a topics.

  • Emite señales hacia la UI cada vez que se recibe un mensaje.

Señales:
data_received (Signal): Emitida al recibir un mensaje MQTT.

Parámetros: (topic: str, payload: str)

data_received
on_connect(client, userdata, flags, reason_code, properties=None)

Callback ejecutado al establecer conexión con el broker.

Parameters:

  • client – Cliente MQTT (paho.Client)

  • userdata – Datos de usuario asociados al cliente.

  • flags – Flags de conexión.

  • reason_code (int) – Código de resultado de la conexión (0 = éxito).

  • properties – Propiedades MQTT v5 (opcional).

Returns:

None

on_disconnect(client, userdata, disconnect_flags, reason_code, properties=None)

Callback ejecutado al desconectarse del broker.

Parameters:

  • client – Cliente MQTT (paho.Client)

  • userdata – Datos de usuario asociados al cliente.

  • disconnect_flags – Flags de desconexión.

  • reason_code (int) – Código de resultado de la desconexión (0 = solicitada, !=0 inesperada).

  • properties – Propiedades MQTT v5 (opcional).

Returns:

None

on_message(client, userdata, msg)

Callback ejecutado al recibir un mensaje de un topic suscrito.

Parameters:

  • client – Cliente MQTT (paho.Client)

  • userdata – Datos de usuario asociados al cliente.

  • msg – Objeto mensaje MQTT (paho.MQTTMessage)

Returns:

None

publish(topic, payload)

Publica un mensaje en el broker.

Parameters:

  • topic (str) – Tópico donde publicar el mensaje.

  • payload (str) – Contenido del mensaje.

Returns:

None

run()

Hilo del cliente MQTT.

  • Conecta al broker.

  • Entra en loop_forever() para mantener la conexión activa.

  • Hilo bloqueante.

Returns:

None

staticMetaObject = PySide6.QtCore.QMetaObject("MQTTClient" inherits "QThread": Methods:   #12 type=Signal, signature=data_received(QString,QString), parameters=QString, QString )
stop()

Detiene el hilo y desconecta del broker.

Returns:

None

subscribe(topic)

Se suscribe a un topic para recibir mensajes.

Parameters:

topic (str) – Tópico a suscribirse.

Returns:

None