Обнаружение изменений состояния ключа
Я новичок в модели программирования Dataflow, и у меня возникли некоторые проблемы, когда я думаю о простом сценарии использования:
У меня есть конвейер, считывающий живые данные из Pub / Sub, эти данные содержат статусы устройства с (упрощенным) серийным номером и состоянием (UP или DOWN). Устройство гарантированно отправляет свое состояние по крайней мере каждые 5 минут, но тогда, конечно, устройство может отправлять одно и то же состояние несколько раз.
Я пытаюсь достичь конвейера, который генерирует только изменения состояния для устройства, поэтому в основном отслеживает некоторое понятие «последнее состояние на ключ» для данного ключа и сравнивает с ним новые события.
Есть ли хороший способ сделать это в данный момент?