Sou novo no modelo de programação do Dataflow e tenho alguns problemas para entender o que acho que deveria ser um caso de uso simples:

Eu tenho um pipeline que lê dados ao vivo de Pub / Sub, esses dados contêm status do dispositivo com (simplificado) um número de série e um estado (UP ou DOWN). É garantido que um dispositivo envia seu estado pelo menos a cada 5 minutos, mas é claro que um dispositivo pode enviar o mesmo estado várias vezes.

O que estou tentando alcançar é um pipeline que emite apenas alterações de estado para um dispositivo, basicamente acompanhando alguma noção de "último estado por chave" para uma determinada chave e comparando novos eventos a ela.

Existe uma boa maneira de fazer isso no momento?