2013-03-13 81 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