问题标签 [wso2cep]

I am using wso2BAM 2.4.1 with wso2ESB 4.6, I first edited the

/repository/conf/etc/bam.xml

file and enabled the ServiceDataPublishing feature. Then I setup the BAM Service Data Pblishing feature from the repository on the ESB. After I configured the Service Data Pblishing and my job on the esb got done.

I used the Cassandra Explorer and saw the logs are saving to the Cassandra under the stream name I set in the ESB Service Data Pblishing configurations.

Everything went well till I installed the Service_Statistics_Monitoring toolbox to view data about services and real-time request and response counts.

Since the stream name in the Service_Statistics_Monitoring and Service data Publishing are the same (both are bam_service_data_publisher) I got error in the esb logs for sending data to BAM. I change the stream name in the ESB and the data publishing error gone but still I can not see any data be shown on the dashboard with the Service_Statistics_Monitoring toolbox and it has errors of no data found like the picture below. I have to mention that data is still published to BAM and saved in a table with the new stream name.

我一直在研究Drools Fusion复杂事件处理组件和WSO2 复杂事件处理器/ Siddhi ，我想知道这些组件中的一个/两个是否能够处理2D 和 3D 事件的空间事件。

我有兴趣创建触发器，例如：

• 如果 2 点之间的距离小于 [X] 英里
• 如果对象在区域/多边形内
• 如果对象在区域/多边形之外

是否可以创建这些触发器，或者我是否需要编写扩展/自定义函数？

如果空间事件是可能的，我在哪里可以找到一些我可以查看的文档。

到目前为止我发现了什么：

流口水融合： http ://blog.athico.com/2009/10/secret-sauce.html | 表明基于空间的问题应该是可能的（但是这是一个旧的来源）。

空间和时间推理的规则引擎？| 类似的问题，但它很老

WSO2 复杂事件处理器/Siddhi：[链接]：wso2.com/about/news/wso2-vp-of-platform-evangelism-to-lead-workshop-on-improving-team-performance-with-big-data-streamin / & [链接]：prweb.com/releases/2014_WSO2/03_StructureData/prweb11661730.htm | 谈到了“空间和时间处理”。

[链接]：mail.wso2.org/mailarchive/architecture/2013-October/013646.html | 关于空间扩展的问题

https://docs.wso2.com/display/CEP310/Writing+Extentions+to+Siddhi | 悉地扩展

（对不起 [Link]: 部分，我似乎不能发布超过 2 个链接，因为我是新来的。）

感谢您的时间和精力！

此致，

丹尼斯

嗨，我有一个输入适配器，可以从 rabbitmq 队列中读取消息。我看到当服务器启动时，在适配器上进行了 subscribe() 调用。但是当 wso2 服务器被关闭时，我没有看到正在调用 unsubscribe()。这使适配器读取并删除消息，直到 jvm 死亡 - 即使 cep 的其他组件似乎已关闭。有没有其他人看到这个？

我试图解决简单的任务： 1. 我想关联 3 个事件A、B、C的发生，以防它们在最后 10 秒内发生。

因此 Siddhi 仅支持 2 加入查询，我认为我无法解决它。在文档中，建议使用多个查询并将它们像这样连接在一起

但这会产生错误的结果，因为流 tempA 中的数据可以存活更长时间，时间窗口未对齐。

也许我缺少了什么。有什么建议吗？谢谢

WSO2 CEP 自定义函数不能用作聚合函数，而是对每一行数据进行操作。

假设我们在输入流中有 value1 和 value2。

• 主机：A，值 1：1，值 2：10
• 主机：A，值 1：2，值 2：20
• 主机：A，值 1：3，值 2：30
• 主机：A，值 1：4，值 2：40
• 主机：A，值 1：5，值 2：50

现在我已经按主机完成了时间批处理和分组。并编写了一个自定义函数来查找 MEDIAN，并且还使用了内置函数 SUM。

但它所做的是，它在分组后对所有 5 行应用 SUM 函数，但自定义函数是逐行调用的。自定义函数类中的 process 方法被逐行调用。因此 SUM 返回 15，但我的 MEDIAN 函数给出的输出为 50，这只是最后一个 value2。

执行计划查询

自定义函数 Java 类片段

我们不能有一个自定义聚合函数，或者如果自定义函数只应该逐行执行？？？

如何在 WSO2-CEP 中动态编写查询。由于在 PSQL 中用户可以选择动态编写查询，CEP 工具中是否有任何替代方法来实现它？

用例： 1. 假设，如果在流中函数和数据都可用，那么必须有一些选项或者通过使一些适配器用户可以动态地制定规则。

例如。

steam : 1. function1:sum, function2: avg, function3: count, value1: 1, value2: 2, value3: 3 2. function1:sum, function2: min, function3: max, value1: 1, value2: 2, value3 : 3

规则应动态创建，如下所示：

1. 选择 sum(value1) 作为 value1，avg(value2) 作为 value2，count(value3) 作为 value 3 from ...。
2. 选择 sum(value1) 作为 value1，min(value2) 作为 value2，max(value3) 作为 value 3 from ...。

谢谢加根

由于 wso2 CEP 3.1.0 中没有 Buckets 概念。wso2 developer studio 3.7.0 是否支持 Wso2 CEP 3.1.0 ？

我正在使用 wso2cep3.1.0。我通过订阅 ActiveMQ 来获取输入。但我想将 wso2cep 的内容输出到 REST api。我怎样才能做到这一点？？

我有许多流进来，我使用 wso2 用规则评估这些流。其中一些流可以捆绑在一起，就像它们来自同一个组织一样。我如何根据这些不同的组织分离我的 siddhi 上下文。

所以基本上我正在寻找的是这样的东西。

siddhimanager.context("context1").defineStream(...)
siddhimanager.context("context2").defineStream(...)

任何帮助将不胜感激 在此先感谢

我正在尝试将 WSO2 CEP 服务器连接到 WSO2 消息代理服务器。

我创建了一个 jndi.properties 文件：

输入事件适配器：

流定义：

和一个事件构建器：

不幸的是，WSO2 CEP 服务器没有收到来自 WSO2 消息代理服务器的消息，并抛出以下异常：

[2014-11-28 13:00:00,226] INFO - {JMSEventAdaptorType} JMS 输入事件适配器加载侦听器 在 java.util.concurrent.ConcurrentHashMap.hash(ConcurrentHashMap.java
的线程“Thread-29”java.lang.NullPointerException 中出现异常
:333)
在 java.util.concurrent.ConcurrentHashMap.get(ConcurrentHashMap.java:988)
在 org.wso2.carbon.event.input.adaptor.jms.JMSEventAdaptorType.createJMSAdaptorListener(JMSEventAdaptorType.java:291)
在 org.wso2。 carbon.event.input.adaptor.jms.JMSEventAdaptorType.tryStartAdaptor(JMSEventAdaptorType.java:262)
at org.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder.loadLateStartEventAdaptors(JMSEventAdaptorServiceHolder.java:66)
在 org.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder$1.run(JMSEventAdaptorServiceHolder.java:43)
在 java.lang.Thread.run(Thread.java:745)

你能帮我调试这个异常吗？