Ich bin neu im Dataflow-Programmiermodell und habe Probleme, mich mit dem zu befassen, was meiner Meinung nach ein einfacher Anwendungsfall sein sollte:

Ich habe eine Pipeline, die Live-Daten von Pub / Sub liest. Diese Daten enthalten Gerätestatus mit (vereinfachter) Seriennummer und Status (UP oder DOWN). Es ist garantiert, dass ein Gerät mindestens alle 5 Minuten seinen Status sendet, aber dann kann ein Gerät natürlich denselben Status mehrmals senden.

Was ich versuche zu erreichen, ist eine Pipeline, die nur Statusänderungen für ein Gerät ausgibt. Verfolgen Sie also im Grunde eine Vorstellung vom "letzten Status pro Schlüssel" für einen bestimmten Schlüssel und vergleichen Sie neue Ereignisse damit.

Gibt es im Moment einen guten Weg, dies zu tun?