2.3 KiB
2.3 KiB
Демо-пайплайн: IoT → SQS → Fission
⚠️ LEGACY — написано до реализации MQ-триггера.
Сейчас MQ-триггер реализован (см. TODO.txt).
Архитектура
-
Крон-функция (Fission)
- Парсит данные о погоде с сайта для нескольких городов
- Эмулирует IoT-датчики: отправляет данные в IoT-сервис (MQTT/HTTP)
-
IoT-сервис
- Принимает данные от "датчиков"
- Публикует сообщения в очередь (SQS или аналог)
-
Очередь (SQS)
- Хранит сообщения от IoT
- Триггерит Fission-функцию при появлении новых данных (MessageQueue Trigger)
-
Fission-функция
- Получает данные из очереди
- Записывает их в таблицу (PostgreSQL, ClickHouse и т.д.)
Требования к Fission
⚠️ LEGACY: MQ-триггер реализован через sqs-consumer (май 2026). Этот раздел оставлен для исторического контекста.
- Необходим MQ-триггер (MessageQueue Trigger) для автоматического запуска функции по сообщениям из очереди.
- Сейчас в Fission есть HTTP, Cron, Event, но нет универсального MQ-триггера.
- Возможные варианты:
- Реализовать внешний watcher (SQS/Kafka/RabbitMQ → invoke HTTP endpoint Fission)
- Добавить поддержку MQ-триггера в сам Fission (новый CRD + контроллер)
Примечания
- Все компоненты связаны через API/очереди, каждый слой изолирован.
- Такой пайплайн типовой для облачных платформ и легко масштабируется.
- Для MVP достаточно watcher-а очереди, который вызывает функцию через HTTP.
Если потребуется — расписать детальный план интеграции или примеры кода для каждого этапа.