3

下午好。

我以建筑师 SW Competence Centers 为 Indra 公司 (www.indra.com) 撰写文章。

在这个领域通常使用 CEP，开源和商业，在开源领域直到现在我们一直使用 Esper CEP，但我们发现 GPL 存在问题。

在我们对尝试 Siddhi CEP 感到好奇之后，我们已经使用这个 CEP 启动了一个项目。

问题是我们发现我们无法识别包含所有 CEP 和项目需求的功能：检测事件的缺失。

在 Esper 中，这可以通过如下查询来完成：

     select a.id, count (*) from pattern [
     every a = Status -> (timer: interval (10 sec) and not Status (id = a.id)
     ] Group by id

     http://esper.codehaus.org/tutorials/tutorial/tutorial.html

我们想知道产品路线图是否包含此功能，以及现在是否有解决此问题的方法。

谢谢和问候。

4

1 回答 1

0

此规则将每 10 秒触发一次新事件未到达。Drools CEP 引擎必须设置为流模式

declare EquipmentFact
@role(event)
@timestamp( lastNotifyTs ) 
originalObject : Object    
equipmentInit : String
equipmentNum : String
   lastNotifyTs : java.util.Date   
   eventTs : java.util.Date
   notifyCnt : int
   maxWait : String
end

规则“设备未在 10 秒内发送”

什么时候

$a: EquipmentFact();
not  EquipmentFact(eventTs > $a.eventTs, equipmentInit == $a.equipmentInit, equipmentNum == $a.equipmentNum, this after [1s, 10s] $a)

然后

System.out.println("#######  FIRED  ######### Second EquipmentFact event did not arrive 10s " + $a);
retract($a);
    EquipmentFact retE = new EquipmentFact();
retE.setEquipmentInit($a.getEquipmentInit());
retE.setEquipmentNum($a.getEquipmentNum());
retE.setEventTs($a.getEventTs());
retE.setNotifyCnt($a.getNotifyCnt()+1);
retE.setLastNotifyTs(new Date());
insert(retE);

结尾

于 2015-05-28T13:11:05.217 回答