Siddhi查询地理栅栏入口检测

Question

我试图让Siddhi在事件检测到飞机进入Geofence时触发事件，但无法完全弄清楚正确的查询。

我有以下的输入流定义：

define stream GeofenceMulticasterConsumerStream (journeyId string, geofenceId string, withinGeofence bool, timestamp long) 

每次我得到一个飞行的位置更新，我得到这个流genereated为系统中的每个地理围栏（事件有大约10个地理围栏等等以为西提将能够处理位置更新事件的10 *号）

这是我开始与查询：

define partition geofencePartition by GeofenceMulticasterConsumerStream.geofenceId; 
from every a = GeofenceMulticasterConsumerStream[withinGeofence == false] -> 
b = GeofenceMulticasterConsumerStream[a.journeyId == b.journeyId and b.withinGeofence == true] 
within 300000 
select b.journeyId, b.geofenceId, b.timestamp as timeEntered 
insert into EnteredGeofenceStream 
partition by geofencePartition 

但是，这给了我重复的Geofence Entry事件，因为它针对每个匹配的“b”事件评估每个“a”事件（如果我有5个事件不在地理围栏中，那么后面是5个地理围栏入境事件）

所以我尝试添加一些重复的事件检测，以避免这种情况：

from every a = GeofenceMulticasterConsumerStream[withinGeofence == false] -> 
b = GeofenceMulticasterConsumerStream[a.journeyId == b.journeyId and b.withinGeofence == true] 
within 300000 
select b.journeyId, b.geofenceId, b.timestamp as timeEntered, geofences:hashEntry(b.journeyId, b.geofenceId, b.timestamp) as entryHash 
insert into DuplicateEnteredGeofenceStream 
partition by geofencePartition 

from DuplicateEnteredGeofenceStream#window.firstUnique(entryHash) 
select journeyId, geofenceId, timeEntered 
insert into EnteredGeofenceStream 

地理围栏：hashEntry是我创建的生成项事件的唯一哈希码的功能。

但是，我并不热衷于这样做，因为您必须记录firstUnique窗口中的所有独特哈希值，并担心这会造成内存泄漏。看起来有点过于顶端，因为哈希将仅适用于该时间点，因此我只需要一个firstUnique窗口，该窗口最多有效几秒钟以检查重复项。

我认为我遇到的一个重大问题是我有一个流有多个航班和多个地理栅栏被追踪，因为我见过的所有例子都更简单我想知道如果我试图实现一些不可能的事情。

我非常感谢任何意见，因为我现在已经没有想法了！

在此先感谢！

Answer 1

由于您试图仅检测到转换a - > b，因此您可以在此处使用“序列”而不是模式。

在Siddhi，当你使用一个序列时，它匹配连续的事件，而没有任何其他事件在中间。相反，模式可以让其他事件在中间存在。

此外，在这种情况下，由于多个航班可能会同时输入相同的地理围栏，因此您必须使用航班ID（或旅程ID）进行划分，而不是使用地理围栏ID进行划分（否则，会有航班X和Y例如X_outside - > Y_outside - > X_inside - > Y_inside，这将不会被检测到）。这样，从outside_fence - > inside_fence的特定航班的过渡将会被正确检测到。

所以，一旦你使用正确的分区与序列，你可以检测到过渡，并没有必要使用独特的窗口等。

有关更多详细信息，请参阅序列号doc here。