WSO2 CEP siddhi Проблема фильтра

Question

Я пытаюсь использовать запрос siddhi langage, но, похоже, я злоупотребляю им.

У меня есть некоторые события со следующим streamdef:

{ 'name':'eu.ima.stat.events', 'version':'1.1.0', 'nickName': 'Flux event Information', 'description': 'Details of Analytics Statistics', 'metaData':[   {name:'HostIP','type':'STRING'} ], 'correlationData':[   {name:'ProcessType','type':'STRING'},   {name:'Flux','type':'STRING'},   {name:'ReferenceId','type':'STRING'} ], 'payloadData':[   {'name':'Timestamp','type':'STRING'},   {'name':'EventCode','type':'STRING'},   {'name':'Type','type':'STRING'},   {'name':'EventInfo','type':'STRING'} ]} 

Я просто пытаюсь фильтровать события с тем же значением отростка и тем же значением потока, используя запрос, как этот:

from myEventStream[processus == 'SomeName' and flux == 'someOtherName' ] 
insert into someStream 
processus, flux, timestamp 

Всякий раз, когда я пытаюсь это сделать, никакого вывода не генерируется. Когда я избавлюсь от фильтра

from myEventStream 
insert into someStream 
processus, flux, timestamp 

все мои события на выходе.

Что случилось с моим запросом?

Answer 1

Я вижу некоторые ошибки заклинания в вашем запросе ... В фильтре вы использовали имя переменной, называемое processus, которое не находится в потоке событий. Вот почему этот запрос не дает никакого вывода. Когда вы создаете ведро в WSO2 CEP, убедитесь, что ведро правильно развернуто на сервере CEP и проверьте консоль управления (CEP BUCKETS -> List).

В вашей ситуации. ведро не будет развернуто из-за неправильной конфигурации, а также будут отображаться сообщения об ошибках, напечатанные в терминале, на котором запущен сервер CEP. После исправления этой ошибки ваш запрос будет работать совершенно без какого-либо вопроса ...

С уважением, Mohan

Answer 2

Учитывая ответ Мохана, переименовать «ProcessType» или изменить свой запрос, как это

from myEventStream[ ProcessType == 'SomeName' and flux == 'someOtherName' ] 
insert into someStream 
ProcessType, flux, timestamp