MQTT + ASI Biont: как AI-агент управляет IoT-телеметрией через Mosquitto и EMQX

Проблема: IoT-устройства есть, а единого мозга нет

Умный дом, теплица, склад или небольшое производство — везде датчики, контроллеры и исполнительные механизмы общаются через MQTT. Данные текут рекой, но анализировать их, принимать решения и отправлять команды обратно вручную — невозможно. Человек физически не уследит за сотней топиков. Нужен AI-агент, который понимает контекст, умеет читать телеметрию и писать команды.

ASI Biont — это AI-агент нового поколения, который подключается к любому MQTT-брокеру (Mosquitto, EMQX, HiveMQ) и берёт на себя весь цикл: сбор данных, анализ, принятие решений, обратную связь через publish. Всё — через обычный чат.

Как ASI Biont подключается к MQTT

ASI Biont использует paho-mqtt — стандартную Python-библиотеку для MQTT. AI-агент пишет код прямо в sandbox-окружении (execute_python) и выполняет его. Пользователь просто описывает в чате:
- адрес брокера (например, mqtt://192.168.1.100:1883)
- логин/пароль (если требуется)
- топики для подписки и/или публикации

Пример диалога:

Пользователь: «Подключись к Mosquitto на 192.168.1.100, подпишись на топик sensor/temperature, читай данные каждые 10 секунд и, если температура выше 30°C, публикуй команду relay/1 со значением ON»

AI генерирует следующий код и выполняет его:

import paho.mqtt.client as mqtt
import time
import json

BROKER = "192.168.1.100"
PORT = 1883
TOPIC_TEMP = "sensor/temperature"
TOPIC_RELAY = "relay/1"
THRESHOLD = 30.0

def on_message(client, userdata, msg):
    try:
        payload = json.loads(msg.payload.decode())
        temp = payload.get("temperature")
        if temp is not None and temp > THRESHOLD:
            client.publish(TOPIC_RELAY, "ON")
            print(f"Опасно! {temp}°C — реле включено")
        else:
            print(f"Температура {temp}°C — норма")
    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()
time.sleep(30)  # работаем 30 секунд (таймаут sandbox)
client.loop_stop()

Код не содержит while True — sandbox ASI Biont имеет таймаут 30 секунд, поэтому AI использует time.sleep() или однократный loop_forever() с таймером.

Реальный кейс: управление теплицей через EMQX

Задача: Автоматизация теплицы с десятком датчиков (температура, влажность, освещённость) и исполнительными механизмами (полив, вентиляция, затенение). Данные публикуются в EMQX, команды уходят на ESP32 через MQTT.

Решение: Пользователь описывает задачу в чате ASI Biont:

«Подключись к EMQX на cloud.emqx.io:1883, логин: admin, пароль: pass123. Подпишись на топики +/sensor/#. Анализируй данные. Если влажность почвы < 40% — опубликуй actuator/pump со значением ON. Если влажность > 70% — OFF. Также отправляй сводку в Telegram каждый час»

AI пишет скрипт, который подписывается на все топики сенсоров (через wildcard +), парсит сообщения, принимает решения и публикует команды. Для отправки в Telegram AI использует requests.post к API Telegram (библиотека requests доступна в sandbox).

Результаты:
- Время на настройку: 3 минуты (вместо 2–3 часов ручного кодинга)
- Реакция на события: < 1 секунды (MQTT — быстрый протокол)
- Экономия на разработке: ~40 000 руб. (стоимость часа разработчика × 8 часов)
- Уведомления в Telegram — прозрачность 24/7

Почему это выгодно

Как начать

1. Зарегистрируйтесь на asibiont.com
2. Создайте API-ключ в разделе Devices и скачайте bridge.py (если используете COM-порты) — для MQTT bridge не нужен
3. Откройте чат с AI-агентом и напишите, к какому MQTT-брокеру подключиться и какие задачи решать
4. AI сам напишет код, выполнит его и начнёт управлять вашими IoT-устройствами

Заключение

MQTT — стандарт де-факто для IoT. ASI Biont превращает его из пассивной шины данных в интеллектуальную систему управления. Вы просто говорите, что нужно сделать, а AI пишет код интеграции. Никаких панелей, никаких кнопок «добавить устройство» — только диалог. Попробуйте уже сегодня на asibiont.com.