问题标签 [siddhi]

我对 WSO2 CEP 有疑问。请建议或解决此问题。

环境如下。
1) CEP 版本为 2.1.0。
2) 使用 TimeBatch 窗口和模式查询。

问题如下。
1) 出现内存不足。
2) 增加线程数。

先感谢您。

我还没有找到任何方法来表达类似“不存在”的查询。

例如，要简单地测试所有设备是否正常，或者如果其中一个设备在给定时间内丢失，则发送警报，查询如下：

请帮忙？

问候。

在 CEP 引擎中，我可以查找未发生事件的模式。

编辑欺诈模式检测查询：如果在一天内两次购买同一张卡并且第一次购买少于 10 美元且第二次购买不超过 10,000 美元，我是否可以触发该事件。

从每 (a1 = purchase[price > 10] ) NOT -> a2 = purchase [price >10000 and 1.cardNo==a2.cardNo] 在 1 天内插入潜在欺诈 a1.cardNo 作为 cardNo，a2.price 作为价格， a2.场所作为场所；

如果在过去一小时内 event1 没有被 event2 跟随，则触发，而不是如果在过去一小时内 event1 被 event2 跟随，则触发？

每当一个事件到达时，都需要一个查询来使用当前事件的值和最后一个事件的值来计算一个新值，并将其插入到一个新的流中。例如：

使用 #window.lengthBatch(2) 时，它允许为每两个事件计算一次加速度。不满足要求。有什么想法吗？

1. 独立模式

   • 当我在我的 linux 机器上启动 WSO2 CEP 服务器时，日志中显示的 IP 地址如下

管理控制台 URL：https://<172.16.55.1>:9443/carbon/

• 当我在该端口上运行 netstat 时，如下所示

linux-0rla:/test/home/CEP/data # netstat -tulpn | grep 9443

tcp 0 0 :::9443 :::* LISTEN 28882/java

• 机器上的 ifconfig 显示

enp0s25 链路封装：以太网 HWaddr 64:31:50:42:93:17
inet addr:10.201.1.171 Bcast:10.201.255.255 掩码：255.255.0.0

vmnet8 Link encap:Ethernet HWaddr 00:50:56:C0:00:08
inet addr:172.16.55.1 Bcast:172.16.55.255 Mask:255.255.255.0

我的机器暴露的 ip 是 10.201.1.171，所以理想情况下 CEP 服务器应该只在这个 ip 上启动。虽然它可以从 eth0 ip 以及从另一台机器访问。

2. 高可用模式

现在，当我为 HA 设置设置类似的 2 台机器时，这一次 thrift ip 也有类似的问题。

• 当我在我的 linux 机器上启动 WSO2 CEP 服务器时，日志中显示的 IP 地址如下

Thrift 服务器开始于 172.16.55.1 Thrift SSL 端口：7711 Thrift 端口：7611

• 当我在该端口上运行 netstat 时，如下所示

linux-0rla:/test/home/CEP/data # netstat -tulpn | grep 7611

tcp 0 0 172.16.55.1:7611 :::* LISTEN 28882/java

但是在这里，这 2 台机器无法通过节俭端口相互通信以进行节点间事件传输。

当我在不同文件夹中的同一台机器上创建 HA 设置时，现在它工作正常。

有没有办法告诉 WSO2 CEP 在特定 IP 地址上启动节俭和服务器？？？

我们可以在 wso2 cep 执行计划中有如下条件语句吗？

用例说明：

假设我有执行计划，它从 3 个不同的流中获取数据。流 1 提供来自设备 1 的数据，来自设备 2 的流 2，......等等。

我已经在数据库中存储了一个表，其中存储了设备总数。在这种情况下，它存储 3 个设备。

现在在执行计划中，我获得了 5 分钟窗口的数据。在这 5 分钟内，只有当我从所有 3 个流中获取数据时，才应该处理数据。否则不应该。

如果在 5 分钟窗口内我只从 2 个流中获取数据，那么执行计划应该丢弃它。

wso2 cep中的元数据相关数据和有效载荷数据是什么

我知道这些是流中的 3 种不同类型的数据类型，但哪种类型的数据类型优于另一种，这在任何文档中都不清楚。或者我们如何在不同的情况下使用它。

所有可以对有效载荷数据执行的操作，我也可以对元数据和相关数据执行。

有人可以用例子解释差异。

我想将卡车对象传递给我的 wso2 siddhi cep 并评估规则以在每次 truck.temperatureReading 低于 45 时发出警报。这可行吗？

我知道以下是正常的做法，但我特定于上述情况。

我一直在研究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 个链接，因为我是新来的。）

感谢您的时间和精力！

此致，

丹尼斯

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 类片段

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