Я смотрю на wso2 cep и пытаюсь понять правильную архитектуру для данных датчиков.
В моем случае мы получаем хорошо сформированные данные.Сущность выглядит следующим образом:
private UUID sensorId;
private Double value;
private Long timeInNanoSeconds;
Эти данные должны быть обработаны, есть сигналы тревоги, которые можно установить на датчиках / значениях.Существуют пользовательские вычисления, в которых значение sensorId X добавляется к sensorId Y.
Правильно ли использовать подход для создания sensorStream и отправки всех данных датчиков со всех устройств / датчиков в этот поток?