Как подписать экземпляр девайса на обновление его telemetry data?
Нужна помощь с идеей архитектуры iot telemetry data (не знаю, как это в реале делается, и боюсь сильно фантазировать):
В приложении spring boot я должна создать новый девайс (из темплейта, например). В сущности есть массив объектов telemetry data: нужно получать от сенсора релевантные данные и постоянно обновлять это поле у сохраненного в бд девайса.
Набросок:
1. Создаю девайс (есть образец по типу девайса, напр.)
2. Ставлю ему "enabled ON" и "subscribed TRUE"
3. Сохраняю его в бд.
4. Делаю триггер какому-то job, чтобы он пошел и добавил этому device топик Kafka для записи (можно ли так делать и как сделать - вопрос)
5. Далее Kafka считывает из общего топика пачками все сообщения (payload у каждого: device_id, data) и по каждому из полученных device_id апдейтит сущность в бд.
6. Если клиент жмет "отключить девайс", то делаю ему enabled - off, subscribed - false в бд и запускаю job, который отменит у сенсора запись в общий топик Kafka (как в реале программно выключить сенсор - я нигде не могу найти)
Извините за поток сознания, но опыта работы с такими системами нет, импровизирую. Буду сильно благодарна за совет
Простой
