问题标签 [wso2si]

我正在尝试使用 WSO2 Streaming Integrator / Siddhi 解析 JSON 事件流，但似乎无法将事件正确地放入流中。我正在使用 dockerimagewso2/streaming-integrator:1.0.0来运行它。

我将以下输入流发送到 SiddhiApp（作为 HTTP POST 到 Siddhi 端点）：

我的流定义如下：

我正在使用邮递员将数据发送到 WSO2 Streaming Integrator，但我得到的只是错误或根本没有响应。

我尝试了以下属性配置，均未成功：

我是否在源定义或映射属性中遗漏了某些内容，或者我是否应该得出结论认为这个数组输入结构是无法使用 siddhi-json 映射解析的？

如果有帮助；这是我简化的应用程序定义：

output every将子句与表子句一起使用时，我遇到了意外的行为join。

• 我有一个基本的应用程序，有一个input流和 2 个表，它们存储不同的值列表。然后，还有2个查询，
• 第一个query1将加入table1，当有匹配时output first every 5 sec。
• Secondquery2将执行类似的操作，将 join table2，并将每 5 秒输出找到的第一个值。
• 这样做的目标是，每 5 秒，当input流中有一个值包含在表 1 中时，就会有一个匹配，如果有一个值包含在表 2 中，就会有一个不同的匹配，并且两者查询将保持沉默，直到下一个 5 秒块。

该应用程序如下

• 运行此应用程序时，首先将其发送到table_input值1，并2填充两个表

• 然后，它开始向输入流重复发送值：1, 2, 1, 2, 1, 2...

• 预计LogStream每 5 秒有 2 个值，第一次出现1value ，第一次出现 value 2。

• 但是相反，只有第一次出现的 value1一直出现，而不是 value2

请注意，当不涉及表连接时，两个查询都按预期工作。没有连接的例子：

这将产生以下输出：

.

我想知道这种行为是否是预期的，或者应用程序的设计中是否存在任何错误。

非常感谢！

我使用Docker Container安装了 WSO2 Streaming Integrator 。本教程中没有关于如何安装编辑器的消息，但我需要有 WSO2 SI 编辑器。请提供一些关于如何安装编辑器以开发 Siddhi 应用程序的要点。

是否有人知道 Stream Integrator 是否可用于实现 mysql 到 mysql 同步¿ 其中数据库 A 的更改反映在 B 中，反之亦然。

提前致谢

我需要将多个事件收集到一个事件中并将其视为一个事件。输出流应包含输入事件作为列表。

基本上，当通过以下事件时

我需要输出如下

如何使用 WSO2 Streaming Integrator 实现这一目标？或 Siddhi.io。

我尝试了以下操作，但它仍然将每个流插入到输出流中

我尝试在 WSO2 SI 的 deployment.yaml 中设置一个数据源连接到 MySQL，以便我可以在我的 Siddhi 应用程序中使用它。它正常工作，但是当我重新启动 MySQL 时，数据源无法重新连接到数据库，因此我的 Siddhi 应用程序出现以下错误。

如何配置数据源以便在数据库重新启动后自动重新连接。

谢谢你，龙。

我正在尝试使用 WSO2 来安排每分钟对我的业务拥有的 REST API 的池数据调用，并将该信息推送到我们的集中式 MQTT 代理。

我一直在阅读 Streaming Integrator、Micro Integrator、Micro Gateway 和 API Manager 的文档，但我找不到任何方法来根据定义的时间安排 REST API 调用。

这项任务的重点是将我们所有系统中的数据推送到我们的集中代理中，然后添加分析工具，以从我们系统创建的数据中受益，这些数据目前只能由系统访问。

有人可以给我一个提示，什么应该是正确的工具，如果软件 wso2 允许的话，也许还有一些关于如何配置时基调用的文档的链接？

这是我的定义：

这是我的查询：

不幸的是，Kibana 无法识别和时间字段，因为它是一个“数字”。

我应该如何以可能的时间戳结束？

编辑：我还可以添加一个问题，我如何使用 WSO2SI 中的地图和 geo_point 类型？

我正在按照 WSO2 文档中的建议运行一个简单的 Siddhi 应用程序，但出现以下异常。我正在遵循以下指南的第 2 步 https://ei.docs.wso2.com/en/latest/streaming-integrator/quick-start-guide/quick-start-guide/ 有人可以告诉我我是什么吗我做错了吗？我有productions.csv

例如，我想将数据流发送RequestStream到 Stream Integrator，但我不知道如何配置它。

我在哪里可以在 Api Manager 中设置 Stream Integrator 的主机和端口以及用户名和密码？

我使用的版本是 4.0.0。

请给我一些建议。

非常感谢