Итак, я оцениваю Кафку.В нашем случае использования пришлось бы создавать новые темы, содержащие «прошедшее время» от одного события к другому, по существу, так как датчик будет сообщать как «включен» или «выключен» в Kafka.Таким образом, имея метку времени, сенсорное имя и состояние, создайте новые темы с длительностью состояний «включено» и «выключено».
- Это возможно в KSQL и как?
- Или действительно нужно оставить это для потребителей или потоковых процессоров, чтобы выяснить это?
Мои данные примерно такие:
{ 2019:02:15 00:00:00, sensor1, off}
{ 2019:02:15 00:00:30, sensor1, on}
, чтобы получить результат
{ 2019:02:15 00:30:00, sensor1, off, 30sec }.
По сути, необходимо объединить состояния нескольких датчиков, чтобы определить объединенное состояние машины.Сотни, если не в конечном итоге тысячи датчиков на заводе