Использование сиддхи 4.1.0
Есть ли возможность применить time.windowBatch к предстоящим событиям? Я понял, что временное окно работает на основе уже поступивших событий.
Скажите, например,
Я получаю несколько результатов при использовании window.timeBatch (2 мин) с предложением group by.
В течение данной 2-минутной продолжительности я периодически пропускал 50 входных событий. Ожидаемое поведение - это все эти события, собранные вместе и представленные в виде единого результата (для проверки используется функция подсчета). Но он дает два результата, например 40 и 10. Неужели первые 40 событий попадают в период одного временного окна, а второе - в следующее окно? В этом случае, как я объединю или получу, что все эти события будут одним выходом в течение 2 минут?
Также я хочу запустить временное окно после прибытия первого события.
Я испытал, что временное окно работает в фоновом режиме, в случае, если события происходят в середине первого временного окна, оно собирает события только в течение 1 минуты. Оставшиеся минутные события собираются в следующее временное окно. Итак, наконец, я получил 2 пакетных результата.
Пожалуйста, предложите другое решение.
Пример использования:
Мой вариант использования основан на продолжительности времени (time.windowBatch (1 мин)) для мониторинга переключателей. Я хотел бы реализовать следующий вариант использования.
Пример использования: коммутатор отправляет ловушки SNMP в CEP. Ловушки похожи на switchFanFailed и switchFanOk.
Если я получаю ловушку switchFanFailed, следующая ожидаемая ловушка switchFanOk будет в пределах 1 мин. Если ловушка switchFanOk не будет получена в течение 1 минуты, CEP сгенерирует уведомление по электронной почте. В противном случае он сбросит эту ловушку.
Несмотря на то, что мой генератор ловушек генерирует ловушки switchFanFailed и switchFanOk в течение 1 минуты как постоянные, в некоторых случаях я не могу получать ловушки в том же окне.
Скажем, например, switchFanFailed приближается к концу 0,50 секунды, отсюда я должен подождать 1 минуту, чтобы ожидать ловушку switchFanOk.
