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。