问题标签 [siddhi]

如何在 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 ...。

谢谢加根

我试图让 Siddhi 在检测到航班进入地理围栏时触发事件，但无法确定正确的查询来执行此操作。

我有以下输入流定义：

每次我获得航班的位置更新时，我都会在此流中为系统中的每个地理围栏生成一个事件（大约有 10 个地理围栏，因此认为 Siddhi 能够处理 10 * 数量的位置更新事件）

这是我开始的查询：

但是，这给了我重复的地理围栏条目事件，因为它评估每个“a”事件与每个匹配的“b”事件（如果我有 5 个不在地理围栏中的事件，然后是一个，我得到 5 个地理围栏条目事件）

所以我尝试添加一些重复事件检测来避免这种情况：

geofences:hashEntry 是我创建的一个函数，它为入口事件生成一个唯一的哈希码。

但是，我并不热衷于这样做，因为您必须在 firstUnique 窗口中记录所有唯一哈希，并担心这会造成内存泄漏。似乎有点过头了，因为散列仅适用于该时间点，因此我只需要一个最多有效几秒钟的 firstUnique 窗口来检查重复项。

我认为我遇到的一个大问题是我有一个包含多个航班和多个地理围栏的流，因为我看到的所有示例都简单得多我想知道我是否正在尝试实现不可能的事情。

我非常感谢您对此提出的任何建议，因为我现在已经没有想法了！

提前致谢！

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

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

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

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

我正在尝试将以下自然语言表达式转换为 WSO2 CEP 中的执行计划。

如果与服务关联的 {CPU load, memory load}, {CPU load, storage load} 或 {memory load, storage load} 对之一的平均负载大于或等于 99%，则发送警报.

首先，我指定了以下执行流：

然后，我指定了以下执行计划：

此执行计划会发送有关服务的警报，但不会发送警报的原因。是否有可能在 Siddhi 中为此目的在查询表达式中创建一个新字符串？沿着：

如果没有，您能否提出替代解决方案？

来自奥斯陆的问候，

亚历山德罗

我是Siddhi语言新手。我只需要在事件流的前 10 分钟内获取事件。有没有办法完成这个任务？这是定义的输入流。

在 CEP 引擎中，我试图做一个像

我找到了这个链接，但我所拥有的不是一个范围......

任何想法？

谢谢！

我在我的项目中使用 Sidhhi CEP 作为 Java 库。现在我需要使用高可用系统（类似于 Esper HA）来分析我的数据。我对 Siddhi 高可用性做了一点研究

http://wso2.com/library/articles/2014/05/high-availability-deployment-in-wso2-complex-event-processor-0/

也通过上述链接

使用 Siddhi java 库可以完成相同的任务吗？？？

我正在尝试做一个简单的查询，但有两个时间窗口；该查询类似于尝试向在过去四个月内访问过网络产品两次以上的用户发送消息，前提是您已在上个月发送了该产品的广告。

并将继续？

当我将参数传递给我的自定义函数并且我想获取它时，我需要这样做：

但是当我有 30 个参数时，我需要重复这个过程近 30 次，当我的输入参数发生变化时，我也必须更改索引。所以我的问题是，是否可以通过他们的名字在 Custom Fuc​​ntion 中获取参数？比如这样：

类似的东西在 Transformer 中可用，但在 Function 中可能吗？

我有一个 userStreamusername,ipaddress,timestamp

我想将此详细信息存储在UserDetailsTable（内存表中）并需要执行upsert。如果用户名和 ipaddress 相同，我怎么能更新该行，否则作为新行插入。

例如：

UserDetailsTable 的结果如下