О поиске паттернов сиддхи

Имеет ли siddhi (http://siddhi-cep.blogspot.com/) / WSO2 возможность работать над запросом, похожим на

1) 5 ошибок с последующим успехом

2) 5 ошибок, за которыми следуют 5 фатальных, за которыми следует 1 успех

можно предположить, что временное окно присутствует

может ли кто-нибудь предоставить пример?


design-patterns wso2 complex-event-processing siddhi
person sabbir    schedule 22.04.2013    source источник
comment
что делает механизм обработки событий? мне это кажется действительно интересным, но я неграмотен о CEP. можешь немного просветить меня?   -  person Newton Sheikh    schedule 22.04.2013
comment
@NewtonSheikh Вы сначала спросили Википедию?   -  person Bernhard Barker    schedule 22.04.2013
comment
О да. но я не мог понять концепцию. движок для обработки событий! что-то вроде хранилища данных?   -  person Newton Sheikh    schedule 22.04.2013

Ответы (2)


arrow_upward
0
arrow_downward

Вы можете выполнить эту задачу, используя реализацию шаблона или последовательности сиддхи (шаблон и последовательность - это две разные реализации, см. Документ) ... см. [1] и [2] ...

[1] http://docs.wso2.org/wiki/display/CEP210/Patterns < / а>

[2] http://docs.wso2.org/wiki/display/CEP210/Sequences < / а>

@ DarkCthulhu: Siddhi - это механизм обработки запросов WSO2 CEP ... (для получения дополнительной информации см. http://docs.wso2.org/wiki/display/CEP210/Introduction+to+SiddhiQL)

Спасибо,

Мохан

person Mohanadarshan    schedule 22.04.2013
comment
благодаря. Еще один вопрос. Можем ли мы применить Pattern.count (...) для подсчета на основе некоторых полей? вроде 5 ошибок на тот же ip? - person sabbir; 23.04.2013

arrow_upward
0
arrow_downward

@Sabbir:

Что касается вашего вопроса о том, можем ли мы применить Pattern.count (...), спрашиваете ли вы, можно ли применять агрегаты, такие как count, avg, max, min, sum, к полям, которые были сопоставлены с шаблоном?

Если да, то ответ отрицательный, это невозможно с текущей версией Сиддхи.

Если вы хотите просто посчитать «нет». ошибок для данного ip вы можете попробовать такой запрос.

from NetFlowStream[status == 'ERROR']#window.time(5 min) 
insert into ErrorNetFlow ipAddr, count(ipAddr) as ipAddrCount
group by ipAddr

Вы можете обратиться к http://docs.wso2.org/wiki/display/CEP210/Windows для получения дополнительной информации о написании оконных запросов для Сиддхи.

Спасибо,

Ласанта

person lasantha    schedule 20.05.2013