Введение
Интернет вещей (IoT) стал повседневной реальностью: миллионы датчиков температуры, умных розеток, контроллеров освещения и систем безопасности ежедневно генерируют терабайты телеметрии. Однако сбор данных — лишь половина задачи. По-настоящему ценным IoT делает способность быстро анализировать информацию и принимать решения: включить вентиляцию, если CO2 превысил норму; отправить уведомление, если давление в трубе упало; скорректировать уставки котла по прогнозу погоды.
MQTT (Message Queuing Telemetry Transport) — стандарт де-факто для IoT-коммуникаций. Брокеры вроде Mosquitto и EMQX обеспечивают надёжную доставку сообщений между сотнями устройств. Но кто будет анализировать эти сообщения и принимать решения? Традиционные решения требуют написания сложной логики на Node-RED, Home Assistant или собственном бэкенде. ASI Biont меняет правила игры: вы просто описываете в чате, что нужно сделать, и AI-агент сам пишет код подключения к вашему MQTT-брокеру, подписывается на нужные топики, анализирует данные и управляет устройствами.
Что такое ASI Biont и как он подключается к MQTT-брокеру
ASI Biont — это AI-агент, который работает в облаке (Railway) и может выполнять Python-код в изолированном sandbox-окружении. Для подключения к MQTT-брокеру ASI Biont использует библиотеку paho-mqtt. Пользователь передаёт в чате параметры подключения: адрес брокера (например, mqtt://192.168.1.100:1883), логин и пароль (если требуется), а также список топиков для подписки. AI-агент генерирует Python-скрипт, который подключается к брокеру, подписывается на топики и в реальном времени обрабатывает входящие сообщения.
Почему именно execute_python?
В отличие от специализированных IoT-платформ, ASI Biont не требует предустановленных драйверов или плагинов. Если устройство говорит по MQTT — AI напишет код под него. Это даёт гибкость: вы можете подключить как датчик температуры за $5, так и промышленный EMQX-кластер с тысячами клиентов.
Как это работает: пошаговый сценарий
Сценарий: Умный термостат на ESP32 + DHT22
Допустим, у вас есть ESP32 с датчиком DHT22, который раз в 10 секунд публикует температуру и влажность в топик sensor/temperature. Вы хотите, чтобы AI-агент:
1. Получал данные с датчика.
2. Анализировал тренд (не выходит ли температура за пределы 18–26 °C).
3. Если температура превышает 26 °C — публиковал команду в топик actuator/fan со значением ON.
4. Если влажность падает ниже 30% — отправлял уведомление в Telegram.
Шаг 1. Опишите задачу в чате ASI Biont
Вы пишете:
«Подключись к MQTT-брокеру по адресу mqtt://192.168.1.100:1883. Подпишись на топик sensor/temperature. Если температура больше 26 °C, опубликуй в топик actuator/fan сообщение ON. Если влажность меньше 30%, отправь мне уведомление в Telegram. Мой Telegram chat_id: 123456789, токен бота: 123:ABC»
Шаг 2. AI-агент генерирует и выполняет код
ASI Biont пишет Python-скрипт с использованием paho-mqtt и requests (для Telegram). Пример кода, который будет выполнен в sandbox:
import paho.mqtt.client as mqtt
import requests
import json
BROKER = "192.168.1.100"
PORT = 1883
TOPIC_TEMP = "sensor/temperature"
TOPIC_FAN = "actuator/fan"
TELEGRAM_TOKEN = "123:ABC"
CHAT_ID = "123456789"
def on_message(client, userdata, msg):
try:
data = json.loads(msg.payload.decode())
temp = data.get("temperature")
humidity = data.get("humidity")
if temp is not None and temp > 26:
client.publish(TOPIC_FAN, "ON")
print(f"Вентилятор включён (temp={temp})")
if humidity is not None and humidity < 30:
url = f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage"
payload = {"chat_id": CHAT_ID, "text": f"Влажность {humidity}% — включите увлажнитель!"}
requests.post(url, json=payload)
except Exception as e:
print(f"Ошибка обработки: {e}")
client = mqtt.Client()
client.on_message = on_message
client.connect(BROKER, PORT, 60)
client.subscribe(TOPIC_TEMP)
client.loop_start() # неблокирующий цикл, чтобы не превысить таймаут
Шаг 3. Автоматизация запущена
AI-агент не просто разово выполнил скрипт — он продолжает слушать брокер. Как только приходит новое сообщение, срабатывает callback on_message. Вы получаете уведомления в Telegram, а вентилятор включается автоматически.
Альтернатива: промышленный сценарий с EMQX
EMQX — это масштабируемый MQTT-брокер, который используется на заводах и в умных городах. Подключение к нему ничем не отличается: ASI Biont поддерживает любые брокеры, совместимые с MQTT 3.1.1/5.0. Пример для EMQX с авторизацией:
import paho.mqtt.client as mqtt
client = mqtt.Client()
client.username_pw_set("user", "pass")
client.connect("emqx.example.com", 1883, 60)
client.subscribe("factory/pressure/#")
client.loop_start()
AI-агент может анализировать показатели давления на разных участках завода и при обнаружении аномалии (резкий скачок) отправлять команду на клапан через топик factory/valve/status.
Почему это выгодно
| Подход | Время на реализацию | Требуемые навыки | Гибкость |
|---|---|---|---|
| Ручное программирование (Python + MQTT) | Часы–дни | Знание Python, MQTT, JSON | Высокая, но требует времени |
| Home Assistant / Node-RED | Часы | Настройка UI, написание скриптов | Средняя (ограничена плагинами) |
| ASI Biont (AI-агент) | Минуты | Только описание задачи на естественном языке | Максимальная (AI пишет любой код) |
По данным опроса IoT-разработчиков (Eclipse IoT Working Group, 2024), более 60% времени при создании IoT-решений уходит на написание интеграционного кода. ASI Biont берёт эту рутину на себя.
Что ещё можно автоматизировать через MQTT + ASI Biont
- Умное освещение: подписка на топик с датчиком движения (
sensor/motion), публикация команд в топик света (actuator/light). - Сигнализация: анализ данных с герконов на окнах, отправка уведомлений при открытии в нерабочее время.
- Энергомониторинг: сбор показаний с умных счётчиков (топик
energy/power), расчёт потребления и отправка отчёта раз в день. - Управление теплицей: контроль температуры, влажности почвы, автоматический полив через реле.
Как начать
- Зарегистрируйтесь на asibiont.com.
- Откройте чат с AI-агентом.
- Опишите вашу задачу: укажите адрес MQTT-брокера, топики и желаемую логику.
- AI-агент сгенерирует код и подключится к вашему брокеру.
Никаких панелей управления, кнопок «добавить устройство» или ручного написания кода — только диалог на естественном языке. ASI Biont поддерживает не только MQTT, но и Modbus, OPC UA, BACnet, SSH, COM-порты, HTTP API и десятки других протоколов. Вы подключаете любое оборудование, а AI делает всю интеграцию за секунды.
Заключение
MQTT-брокеры — это кровеносная система IoT, но без интеллекта они остаются просто шиной для сообщений. ASI Biont превращает ваш Mosquitto или EMQX в полноценного AI-помощника, который понимает, что значат данные с датчиков, и принимает решения без участия человека. Попробуйте интеграцию прямо сейчас на asibiont.com — опишите свою задачу в чате и убедитесь, что автоматизация может быть простой.
Комментарии