wso2cep

0熱度

1回答

根據我在文檔和源代碼上閱讀的內容，WSO2CEP作爲被動軟件工作，所以它只會在流事件到達時發揮作用。所以如果我想在流上開發一些「健康檢查」，我需要自己實施。我的問題是，有沒有人有第一步如何做到這一點？我從哪裏開始有點失落。我是否使用InputEventAdapterFactory或TimeWindowProcessor？我的場景是「簡單的」，如果一個流沒有到達x時間，我需要創建一個警報。感謝，

1熱度

1回答

有沒有什麼辦法可以在siddhi查詢語言的「group by」後刪除逗號？

我在執行計劃中有下面的代碼。 from ocs_in#window.custom:ocs(20 sec,msisdn,package,rent,content) select msisdn as msisdn,content as message group by msisdn insert in

1熱度

1回答

保存窗口數據 - WSO2 CEP

我正在使用獨特的窗口。我想保存窗口狀態或數據。因爲當CEP重新啓動窗口數據將會丟失。有沒有辦法做到這一點？

1熱度

1回答

在WSO2 CEP樣本模式下啓動樣本0009

我試圖在WSO2 CEP中試用樣本0009。它用於JMS協議中的MAP事件。當我試圖在樣本模式i執行在窗口下面的命令來運行在樣品/ CEP /僞影的樣品運行WSO2 CEP： wso2cep-samples.bat -sn 0009 這會導致以下錯誤：無效號碼。數字常量是十進制（17），十六進制（0x11）或八進制（021）。 0預計在這個時候。雖然，當我運行0011的樣本模式沒有顯示該類錯

0熱度

1回答

可以esper/siddhi根據組生成新的流？

我想將每個組分成一個新的流（我希望爲該組操作，而不是流）。有沒有什麼方法可以在esper或siddhi中做到這一點？

0熱度

1回答

wso2 cep externalTime問題

根據用戶指南，我認爲externalTime窗口（時間戳，時間值）應該保持事件只在範圍內：從時間戳到時間戳+時間值。例如，在執行計劃 from input select time:timestampInMilliseconds(time:dateAdd("2016-11-14 19:40:00", 5, 'minute',"yyyy-MM-dd HH:mm:ss"),'yyyy-MM-dd H

1熱度

1回答

來自Hazelcast的事件表

我正在使用下面的執行計劃來填充我的hazelcast支持的事件表。問題是，如何從其他執行計劃重用此現有的支持hazelcast的事件表？這是另一個similar question的後續問題。 @Import('users:1.0.0') define stream users (meta_name string, correlation_id int); @from(eventtable

0熱度

2回答

如何在wso2cep中設置事件流的優先級？

比方說，我們有幾個事件流。其中一些將參考數據加載到hazelcast事件表中，而另一些則是實際的事件處理器。我的目標是，當wso2cep服務器啓動時，它首先將運行哪個加載參考數據hazelcast事件表那麼它會啓動其他流的那些事件流。這將幫助我們保持在所有的事件流處理器參照數據的一致性。

0熱度

2回答

WSO2 CEP雙向REST API

我正在使用wso2 cep 4.1 我創建了接收器來從我的源中捕獲一些json數據。然後我在內部處理這些數據，並且應該給出響應的附加數據。我的迴應應該與數據進入CEP時的相同點。它是經典的休息API。這是可能的嗎？我該如何做到這一點？或者，我需要websocket（websocket-local）用於類似的目的？

1熱度

1回答

WSO2 CEP和SQL服務器插入到與SQL Server端設置主鍵

我有具有以下結構的表的SQL服務器上的數據庫： ID has IDENTITY set to true. 當我進入WSO2 CEP和儘量使流傾倒的事件，將我收到以下錯誤表： from MessageStream insert into msg; Error while dispatching events: Error while adding events to event table