问题标签 [wso2sp]

我想使用 WSO2 流处理器将 CSV 文件转换为一组 Siddhi 事件，以便使用该 CSV 文件来训练 kmeansIncremental 模型。

我尝试使用“文件”作为源类型和“csv”作为地图类型来获取该 csv 文件，但是我不能这样做。

定义流ProductionStream（纬度双精度，经度双精度，频率整数，日期整数，时间间隔双精度，res_ratio双精度，client_id字符串）；

我怎样才能做到这一点？

是否可以在 http sink 请求中生成和使用动态 URL 作为 publisher.url？

我有一个接受参数的输入流。根据我在此流中传递的值，这应该作为基本 URL 的一部分包含在内，它将接收来自另一个流的参数。

我希望附加var为我的基本 URL 的一部分，这是 http-sink 请求的发布者 URL。

悉地有这样的规定吗？

我试图在 WSO2 容器中导出变量。但是当我试图在 siddhi 文件中检索它时，它返回 null。我能够获取预定义环境变量 HOME、PATH 等的数据

我!pip install pysiddhi在 Spyder 的 IPython 控制台上运行时收到此消息。

我正在尝试使用 Spyder 3.7 在 Windows 上安装该库。

我正在研究流处理器 4.3.0。我遇到了一种情况，我使用 siddhiapp 将一些数据馈送到 rdbms 表中。使用 siddiapp，我在 RDBMS 表中输入数据，如下所示

现在，我正在使用另一个 SiddhiApp 来检索数据，但我想尝试以如下方式获取数据

由于公共列被缩小以进入一行，并且现在对具有计数的列求和以获得所有计数的最终总和。

有人可以指导我如何在这里进行。

提前致谢

这是获得总和的应用程序

我在这里所做的唯一更改不是从数据库表中获取值，而是将其视为流（因为聚合只能针对流进行，我想）。

我的意图是在 siddhi 中合并来自两个流的属性。

我正在使用带有 window 属性的“join”来合并我的 siddhi 查询中的两个流，并将连接的结果输入到另一个流中以丰富它。

当传入事件以 1 秒或更长的时间间隔出现时，窗口属性（window.time(1 sec) 或 window.length(1)）效果很好。

当（例如 10 或 100 个）事件同时（在一秒钟内）发送时。那么连接的结果不是预期的。

请让我知道是否有任何方法可以合并两个流，即使一次（在一秒钟内）发送的事件数量很大，也必须对传入事件进行唯一处理/处理。

我正在尝试使用通过“http-response”响应接收器填充的附加属性来丰富我的输入流。

我尝试使用带有 window 属性的“join”和“every”关键字来合并两个流并将生成的合并流插入另一个流以丰富它。

当传入事件以 1 秒或更长的时间间隔出现时，窗口属性（window.time(1 sec) 或 window.length(1)）和“every”关键字效果很好。

当（例如 10 或 100 个）事件同时（在一秒钟内）发送时。然后合并的结果不是预期的。

具有“window”属性的那个（join）

**

**

带有“every”关键字的那个

**

**

有没有更好的方法来合并两个流以更新第三个流？

在将 wso2 apim 分析与 wso2 apim 套件集成后，我有这个日志。该模式完全分布在 k8s 集群中。我使用 jartoboundle.sh 脚本将 postgresql 驱动程序转换为 osgi boundle。分析在一开始确实有效，但一段时间后我不断收到这样的错误和关于 ssl 的错误（无法借用 ssl 客户端）。什么可能导致问题？谢谢你

我试图从 mongodb 集合中加载数据。该集合包含超过 10M 的文档，我找不到任何方法来限制 SP 加载的文档数量。

显然 WsoSO 将所有文档加载到内存中，wisch 引发了 java out-of-memory 错误。

请问有什么建议吗？

谢谢

我正在使用 WSO2 流处理器，我需要使用具有“。”属性的流。和 '@'。

有什么方法可以使用它们吗？例如替换传入事件中的值或类似的东西。这是因为我的传入事件有一些带有“。”的字段。并且 '@' 和 editor 不处理它们。

我尝试使用这些流：