import paho.mqtt.client as mqtt

# Обработчик сообщений от MQTT-сервера
def on_message(client, userdata, message):
    print("message received ", str(message.payload.decode("utf-8")))
    print("message topic=", message.topic)
    print("message qos=", message.qos)
    print("message retain flag=", message.retain)


broker_address = "hairdresser.cloudmqtt.com" # Адрес брокера
username = "zjqvfibx" # Логин
password = "aXRFsHdgZcrB" # Пароль

print("Открытие нового подключения к MQTT")
client = mqtt.Client("P1") # Экземпляр MQTT-сервера
client.on_message = on_message # Установка функции обработчика сообщений
client.username_pw_set(username="zjqvfibx", password="aXRFsHdgZcrB") # Установка аутентификационных данных

print("Подключение к брокеру")
client.connect(broker_address, 16583) # Подключение к брокеру

client.loop_start()

print("Подписываемся на устройство", "/controls/light1/stat/POWER")
client.subscribe("/controls/light1/stat/POWER") # Подписываемся на устройство

print("Отправляем значение OFF", "/controls/light1/cmnd/POWER")
client.publish("/controls/light1/cmnd/POWER", "OFF")  # Отправка сообщения на MQTT-сервер

print("Отправляем значение ON", "/controls/light1/cmnd/POWER")
client.publish("/controls/light1/cmnd/POWER", "OFF")

print("Получаем состояние устройства", "/controls/light1/cmnd/POWER")
client.publish("/controls/light1/cmnd/POWER")

client.loop_stop()