Proton CEP Fiware: удалить старые полученные события
У меня такая проблема с Proton CEP: у меня сейчас EPA "Sequence"; на его входе 2 события. Но эти события имеют разную гранулярность: допустим, у меня есть события A и B; я получаю N "A" событий и M "B" событий, где M << N. Так что я хотел бы иметь правило типа "если событие типа A не используется в течение X секунд, удалите его", в противном случае я длинная очередь событий; мне нужно, чтобы правило оценивалось только для ближайших (временных) событий. Практически, у меня есть поддельный датчик температуры в помещении, который посылает свои обновления температуры каждые 5 секунд, и у меня есть другая программа, которая проверяет внешнюю погоду и отправляет ее каждую минуту.
Есть идеи, как решить эту ситуацию?
Большое спасибо!
2 ответа
Все соответствующие экземпляры событий хранятся в локальном состоянии соответствующего EPA. Для каждого операнда EPA у вас есть политики, которые определяют, как собирается состояние и как создается набор соответствия для вывода событий. Например, политика выбора экземпляров, которая определена для каждого операнда и имеет значения "Each", "First" и "Last", сообщит вам, все ли экземпляры A проверены на совпадение с экземпляром B, или первыми (в порядке прибытия) или последний. Политика потребления говорит, что делать с состоянием операнда, как только обнаружена последовательность, - если экземпляры, скажем, A, которые участвовали в последовательности, будут удалены из состояния EPA ("потреблять" значение политики) или они останутся.
Игра с комбинацией этих политик должна дать вам поведение, которое вам требуется
Я предполагаю, что под словом "потреблять" вы подразумеваете прибытие, поэтому вы хотите оценить время, которое потребовалось событию А, чтобы добраться до протонного ПК? или время между событиями А? Хотите ли вы, чтобы события A действительно были непрерывными с фиксированной скоростью? "Удаление" события означает его игнорирование, поскольку события нигде не хранятся, а только обрабатываются. В конце концов, что вы хотите обнаружить здесь? Мол, какова тенденция комнатной температуры по сравнению с наружной температурой? затем выдавать выходные события соответственно?
Благодарю.