Есть ли какой-либо документ/статья, объясняющая жизненный цикл события в WSO2 CEP? Я не совсем понимаю, как события отбрасываются из потоков событий.Жизненный цикл WSO2 CEP
Спасибо, Уго Calado
Есть ли какой-либо документ/статья, объясняющая жизненный цикл события в WSO2 CEP? Я не совсем понимаю, как события отбрасываются из потоков событий.Жизненный цикл WSO2 CEP
Спасибо, Уго Calado
События будут удалены немедленно. Основной поток - это поток, который будет получать события от и приемников, и он сразу же отправит события издателю без сохранения. Если вы хотите собирать событие в течение определенных периодов времени, вы можете использовать что-то наподобие временных окон в Планах исполнения Сиддхи [1].
В следующем запросе Сиддхи он собирает события в течение 10 минут и вставляет в AvgTempStream путем вычисления среднего потока. В этом случае события будут храниться в памяти в течение 10 минут.
from TempStream#window.time(10 min)
select avg(temp) as avgTemp, roomNo, deviceID
insert all events into AvgTempStream;
[1] https://docs.wso2.com/display/CEP400/SiddhiQL+Guide+3.0#SiddhiQLGuide3.0-Window
Не является ли это полезно? https://docs.wso2.com/display/CEP310/Getting+Started+with+CEP –
Я уже прочитал эту статью и выполнил несколько примеров. Однако я не могу понять, каковы критерии WSO2 CEP, чтобы отметить событие как одноразовое. Событие не может жить в памяти навсегда, иначе у нас будут ошибки в памяти. –