2013-03-13 103 views
0

我正在嘗試使用siddhi查詢語言,但似乎我濫用了它。WSO2 CEP siddhi篩選問題

我有一些事件有以下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 

我所有的事件都在輸出。

我的查詢出了什麼問題?

回答

0

我可以在查詢中看到一些拼寫錯誤...在過濾器中,您使用了一個名爲「processus」的變量名,它不在事件流中。這就是爲什麼這個查詢不提供任何輸出。在WSO2 CEP中創建存儲桶時,請確保存儲桶已正確部署在CEP服務器中並檢入管理控制檯(CEP BUCKETS - > List)。

在你的情況。由於配置錯誤,桶將不會部署,並且在CEP服務器運行的終端中將顯示錯誤消息。糾正這個錯誤後,您的查詢將完美運行沒有任何問題......

問候, 磨憨

0

考慮到磨憨的回答,重命名「ProcessType」或者改變您的查詢像這樣

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