Я работаю над решением, которое получает данные от датчиков температуры;каждый датчик посылает показания каждые несколько минут;входящие показания публикуются в теме PubSub.Решение будет анализировать данные датчика, чтобы найти проблемы, основанные на конфигурации пользователя - таким образом, для датчика 1 пользователь может захотеть получить уведомление, когда температура превышает заданный порог в течение более 30 минут;для другого датчика пользователь может захотеть получить уведомление о том, что температура превышает заданный порог в течение более 20 минут.
Мы думаем об использовании потока данных для обработки входящих данных - сначала преобразуйте данные в несколько наборов ПК (по одному на датчик), а затем используйте Windowing, чтобы подразделить PCollections на датчик.Продолжительность окна должна основываться на конфигурации для этого датчика, но мы пришли к выводу, что это невозможно - длительности окна являются глобальными.
Кто-нибудь использовал Поток данных для определения пользовательских окон для каждой сущностив их пиплелине?