Я новичок в модели программирования Dataflow, и у меня возникли некоторые проблемы, когда я думаю о простом сценарии использования:

У меня есть конвейер, считывающий живые данные из Pub / Sub, эти данные содержат статусы устройства с (упрощенным) серийным номером и состоянием (UP или DOWN). Устройство гарантированно отправляет свое состояние по крайней мере каждые 5 минут, но тогда, конечно, устройство может отправлять одно и то же состояние несколько раз.

Я пытаюсь достичь конвейера, который генерирует только изменения состояния для устройства, поэтому в основном отслеживает некоторое понятие «последнее состояние на ключ» для данного ключа и сравнивает с ним новые события.

Есть ли хороший способ сделать это в данный момент?