问题标签 [siddhi]

我正在开发一种具有自定义执行计划生成器功能的工具。因此，通过使用此工具，最终用户可以在 WSO2 CEP 中创建大量执行计划。我对此有以下三个担忧。

1) 在 CEP 中有大量执行计划时，是否会对性能产生相当大的影响？可能有大约 100,000 个执行计划。

2）当有大量执行计划时如何分组？

3）最后我想将执行计划加载到我的工具的 UI 中。因此最终用户可以自定义它们。那么是否有一个执行计划解析器，所以我们可以传递它并将其作为对象获取。或有关将执行计划加载到 UI（Java 程序）的任何其他建议。

谢谢

我使用 WSO2 CEP v4.1.0 创建了带有风暴支持的简单执行计划。但是当我在 Siddhi 中使用窗口设施时，它会给出一些例外。并且它也不可能使用风暴将表与流连接起来。我该如何解决这个问题？有没有其他选择。

执行计划

CEP 给出的错误

异常：指定的分布式查询无效，转换为 XML 风暴查询计划时出错。执行计划：ExecutionPlan 租户：-1234。部署查询时出错：@name('query1') @dist(parallel='8', execGroup='Filtering') from InputStream#window.time(1 sec) select id as id, param3 as param3 insert into OutputStream 并行有对于窗口、连接和模式查询为 1。

我编写了一个自定义的 http 接收器，它从另一个系统获取事件，json 示例如下：

接收者将json一一发送到包含字段的流名称“tag_input_stream”：

现在我有另一个流名称 format_tag_stream 其中包含字段：

我想将值从 tag_input_stream 插入到 format_tag_stream 中，如下所示：

我使用执行计划来编写 siddhi 脚本：

但它不起作用。如何编写脚本，有什么例子吗？谢谢

我正在尝试构建一个执行计划，将不同的事件聚合为一个并计算发生次数（CurrentEventId）。该计划如下所示：

实际上，我有以下输出：

我每 10 秒只需要一个事件，而不是多个事件。此事件应具有以下格式：

你知道如何实现这一点吗？

I'm new to Siddhi, and I got several questions:

1. Is SiddhiManager thread safe? Is it a good practice one shared instance per JVM?

2. How to define stream and add query at runtime? It seems it only has siddhiManager.createExecutionPlanRuntime(plan) which will create a new ExecutionPlanRuntime instance. And how to redefine stream and query?

3. What's inEvents and removeEvents in QueryCallback?

   /li>
4. How would Siddhi scale, if I have lots of stream and queries?

Thanks!

我使用 Siddhi CEP 3.0.2 作为独立库。我有一个带有以下流和查询定义的执行计划，以关联连续事件并检测更改。我正在调用自定义函数调用。流定义中提到的对象属性是自定义 java 对象和 java.util.Map 对象类型。

在每个事件定期发生 5 分钟后，我可以看到 CPU 利用率在一秒钟内达到 40% 到 50% 左右，然后逐渐下降。但是这个 CPU 利用率每 5 分钟就会增加一次。

我使用模式查询的方式有问题。对此有什么帮助吗？

我有一个 postgres 黑名单表，我想加载这个表并使用 WSO2 DAS 的事件表进行连接。

但它不允许我在查询中使用黑名单吃。

这是我的示例代码：

这是错误：

“ID 为“Trazablack”的流/表定义尚未在执行计划“ExecutionPlan”中定义”

这是可能的？

我正在使用嵌入在 WSO2 DAS 中的 WSO2 CEP 用于以下执行计划

每个输出事件产生两次相同的值

事件消息跟踪器日志如下

流一（InputStream）

流二（RelatedStream）

输出流（matchingStream）

我有个问题。我正在使用 DAS 3.0.1。

Trazablack 是一个 postgres 表。

我无法加入 Trazafiltrada 事件，它是使用以下代码创建的：

但是，我想加入其他不同的事件，我正在使用下一个代码：

我的问题是这个查询是空的。为什么？

我想从 siddhi 读取 postgres 表，并且我正在使用触发器：

但是，我有一个问题，查询每 10 分钟运行一次，我需要在新事件到达时运行。

这可能吗？