wso2cep

0热度

1回答

WSO2 CEP +处理空值

当前使用一些Http请求触发WSO2 CEP。但有时触发的请求具有空值。那时候如何使用CEP来处理这些空值。

1热度

1回答

WSO2 CEP性能

我有几个与WSO2 CEP性能有关的问题。一秒钟内可以处理多少个事件？一次可以处理多少个执行计划而无需执行性能变化巨大？接收者和发布者的最大数量是多少，可以将添加到CEP中？可以添加到CEP的执行计划的最大数量是多少？

2热度

1回答

WSO2 esb UDP到TCP转换 - 提高性能

我想将UDP流转换为TCP/HTTP并将其馈送到WSO2 CEP。因此，对于UDP到HTTP的转换，我使用WSO2 ESB。正如我所看到的，可以使用ESB代理平滑地将大约2000UDP消息转换为HTTP。在这种情况下，ESB花费了大约2.2GB的RAM。但是我需要比这更多的性能（每秒大约50,000次转换）。我的转换ESB代理如下。有什么方法可以实现以上的表现？（我假设这里使用HTTP NIO

0热度

1回答

WSO2 CEP使用Teradata数据库连接的事件表抛出空异常

我尝试在Siddhi引擎中使用事件表，并通过JDBC Teradata驱动程序连接到Teradata数据库。 Teradata Database作为安装了WSO2CEP的计算机上的虚拟机运行。所有我已经把Teradata的JDBC驱动程序terajdbc4.jar在 <WSO2CEP_HOME>/repository/components/lib/ 目录，和驱动程序的附加部分的首先tdgss

3热度

1回答

WSO2 CEP Siddhi窗口和表格连接不支持Apache Storm

我已经使用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回答

将WSO2 CEP Siddhi事件聚合到单个json对象

我试图构建一个执行计划，它将不同的事件聚合为一个并计算出现次数（CurrentEventId）。该计划看起来如下： define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId int); partition with (CurrentEventId of inStream) beg

1热度

1回答

WSO2 CEP/DAS - MQTT连接无法访问MqttException（0） - java.lang.NullPointerException

我发现当CEP/DAS收到一个MQTT流事件，其中有一个STRING属性中的null值时，激发java.lang .NullPointerException并关闭MQTT连接。下面是示例 WORKS（sensorName有一个值） { "event": { "metaData": { "timestamp": 4354643, "isPowerS

0热度

1回答

wso2 cep错误，同时创建事件接收器kafka类型

第一次成功创建事件接收器类型kafka。然而第二个，当我再次运行kafka并从wso2 cep创建一个新的事件接收器。它显示讯息如下 "Failed to add event receiver, Exception: java.lang.NoClassDefFoundError: org/apache/kafka/common/security/JaasUtils" ，并没有添加新的事件接收器。

1热度

1回答

WSO2 CEP 4.1.0事件适配器

我写了一个自定义事件适配器，并将该jar放入了丢弃文件夹，但CLI不显示自定义日志记录，也不显示在输出适配器中。我已阅读4.1.0指南没有成功，并试图读取源代码： http://dist.wso2.org/maven2/org/wso2/carbon/org.wso2.carbon.event.input.adaptor.email/1.0.1/