Soy nuevo en el modelo de programación de Dataflow y tengo algunos problemas para entender lo que creo que debería ser un caso de uso simple:

Tengo una tubería que lee datos en vivo de Pub / Sub, estos datos contienen estados del dispositivo con (simplificado) un número de serie y un estado (ARRIBA o ABAJO). Se garantiza que un dispositivo envíe su estado al menos cada 5 minutos, pero luego, por supuesto, un dispositivo puede enviar el mismo estado varias veces.

Lo que estoy tratando de lograr es una canalización que solo emite cambios de estado para un dispositivo, por lo que básicamente hace un seguimiento de alguna noción de "último estado por clave" para una clave determinada y compara nuevos eventos con eso.

¿Hay una buena manera de hacer esto en este momento?