PAHO MQTT PYTHON ПРИМЕР

Библиотека Paho MQTT для Python предоставляет возможность реализации протокола MQTT (Message Queue Telemetry Transport) для обмена сообщениями между приложениями. Протокол MQTT обычно используется для передачи сообщений в IoT-устройствах, но может быть применен и в других областях.

Для использования библиотеки Paho MQTT в Python, необходимо установить ее через pip:

pip install paho-mqtt

Пример подписки на MQTT-топик и печати полученного сообщения:

import paho.mqtt.client as mqttdef on_connect(client, userdata, flags, rc):    print("Connected with result code "+str(rc))    client.subscribe("test/topic")def on_message(client, userdata, msg):    print(msg.topic+" "+str(msg.payload))client = mqtt.Client()client.on_connect = on_connectclient.on_message = on_messageclient.connect("mqtt.eclipse.org", 1883, 60)client.loop_forever()

В данном примере мы создаем экземпляр класса mqtt.Client() и устанавливаем его callback-функции on_connect() и on_message(). Затем подключаемся к брокеру MQTT и начинаем бесконечное ожидание сообщений с помощью функции loop_forever().

Пример публикации сообщения в MQTT-топик:

import paho.mqtt.publish as publishpublish.single("test/topic", "Hello, world!", hostname="mqtt.eclipse.org")

В данном примере мы используем модуль paho.mqtt.publish для отправки сообщения "Hello, world!" в топик "test/topic" на брокере MQTT.