2015-09-07 84 views
0

我的用例是識別在X實時時間後沒有收到預期事件的實體,而不是使用批量作業。例如:使用Esper實時註冊觸發器以查找丟失的預期事件

如果我們在時間T已收到PaymentInitiated事件,但沒有收到T + X的PaymentFailed/PaymentAborted/PaymentSuced中的任何一個,那麼引發一個觸發器,說明PaymentStuck以及PaymentIntitiated事件的詳細信息。

1.我可以使用Esper捕獲這樣的觸發器嗎?

在我的實際使用情況中,X不是常數,而是根據我在第一個事件發生之前知道的每條記錄而變化。

2. Esper是否支持在X不恆定的情況下注冊這樣的動態查詢?

謝謝, 哈里什

回答

1

你可以使用一個圖案,如「模式[每PI = PaymentInitiated - >定時器:間隔(pi.amountOfTimeInSeconds),而不是(PaymentAborted(ID = pi.id)或PaymentStuck (id = p.id))]「 外連接也可以方便地檢測缺勤。 Esper網站中的解決方案模式頁面有更多示例。

+0

完美。感謝提示使用事件數據本身作爲條件的一部分。想知道通過動態數據。 – Harish

相關問題