wso2cep

    0熱度

    1回答

    當前使用一些Http請求觸發WSO2 CEP。但有時觸發的請求具有空值。那時候如何使用CEP來處理這些空值。

    1熱度

    1回答

    我有幾個與WSO2 CEP性能有關的問題。 一秒鐘內可以處理多少個事件? 一次可以處理多少個執行計劃而無需執行 性能變化巨大? 接收者和發佈者的最大數量是多少,可以將 添加到CEP中? 可以添加到CEP的執行計劃的最大數量是多少?

    2熱度

    1回答

    我想將UDP流轉換爲TCP/HTTP並將其饋送到WSO2 CEP。因此,對於UDP到HTTP的轉換,我使用WSO2 ESB。正如我所看到的,可以使用ESB代理平滑地將大約2000UDP消息轉換爲HTTP。在這種情況下,ESB花費了大約2.2GB的RAM。但是我需要比這更多的性能(每秒大約50,000次轉換)。 我的轉換ESB代理如下。有什麼方法可以實現以上的表現? (我假設這裏使用HTTP NIO

    0熱度

    1回答

    我嘗試在Siddhi引擎中使用事件表,並通過JDBC Teradata驅動程序連接到Teradata數據庫。 Teradata Database作爲安裝了WSO2CEP的計算機上的虛擬機運行。所有我已經把Teradata的JDBC驅動程序terajdbc4.jar在 <WSO2CEP_HOME>/repository/components/lib/ 目錄,和驅動程序的附加部分的 首先tdgss

    3熱度

    1回答

    我已經使用WSO2 CEP v4.1.0創建了帶風暴支持的簡單執行計劃。但是,當我在Siddhi使用窗戶設施時,會有一些例外。而且它也不可能與流一起使用風暴來加入桌面。我該如何解決這個問題?有沒有其他選擇。 執行計劃 @Plan:name('ExecutionPlan') @Import('InputStream:1.0.0') define stream InputStream (id s

    2熱度

    1回答

    我寫了一個自定義HTTP接收流轉換,它獲得的事件從另一個系統,並且json樣品,如: {"tag":"A01","time":"10:01:00","value":"30.01"}, {"tag":"A01","time":"10:01:01","value":"35.01"}, {"tag":"A01","time":"10:01:02","value":"31.01"}, {"tag":

    2熱度

    1回答

    我試圖構建一個執行計劃,它將不同的事件聚合爲一個並計算出現次數(CurrentEventId)。該計劃看起來如下: define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId int); partition with (CurrentEventId of inStream) beg

    1熱度

    1回答

    我發現當CEP/DAS收到一個MQTT流事件,其中有一個STRING屬性中的null值時,激發java.lang .NullPointerException並關閉MQTT連接。 下面是示例 WORKS(sensorName有一個值) { "event": { "metaData": { "timestamp": 4354643, "isPowerS

    0熱度

    1回答

    第一次成功創建事件接收器類型kafka。然而第二個,當我再次運行kafka並從wso2 cep創建一個新的事件接收器。 它顯示訊息如下 "Failed to add event receiver, Exception: java.lang.NoClassDefFoundError: org/apache/kafka/common/security/JaasUtils" ,並沒有添加新的事件接收器。

    1熱度

    1回答

    我寫了一個自定義事件適配器,並將該jar放入了丟棄文件夾,但CLI不顯示自定義日誌記錄,也不顯示在輸出適配器中。 我已閱讀4.1.0指南沒有成功,並試圖讀取源代碼: http://dist.wso2.org/maven2/org/wso2/carbon/org.wso2.carbon.event.input.adaptor.email/1.0.1/