问题标签 [wso2si]

我试图将我的 postgresql 数据库与 wso2 流集成器工具连接，知道我已经安装了 Change Data Capture - PostgreSQL 和 RDBMS - Postgre SQL 扩展，并且我对 db 坐标感到满意，所以请

我想从 CSV 文件中读取一百万条记录，并使用 WSO2 流式集成器写入另一个 CSV 文件。问题是读写数据的速度很慢，几乎每秒10次。WSO2 说“在 20 分钟内读取包含 1000 万行的 100GB 文件”，但我没有找到这样做的示例或指南。谁能帮我？

我是 WSO2 流式集成器的新手。我正在使用带有 OpenJDK 版本“11.0.11”2021-04-20 的 Ubuntu 20.*，因为 Java 是 WSO2 SI 的后端。

我正在创建一个 Siddhi 应用程序，我在其中尝试使用 Siddhi 应用程序扩展访问 Cassandra 数据库。默认情况下没有提供这个扩展，所以我安装了它。成功安装扩展后，当我编写访问 Cassandra 数据库的代码时，如下所示

我面临以下错误：

在处理 Cassandra 查询配置时找不到键空间 testError 的 cassandra 配置：在模块路径或类路径上找不到 JAXB-API 的实现

我google了很多来解决这个问题。许多人回答说我必须添加 JAXB-API 依赖项，但我不知道怎么做，因为我从来没有使用过 Java。我试图找到 JAXB-API 的实现方式，但没有找到合适的实现方案。

请问有人可以帮我解决这个问题吗？很多人都会对他们表示赞赏。

有问题的加法

这是为了澄清 Cassandra 数据库正在成功运行，因此从终端运行 Cassandra 数据库或使用任何 UI 都没有问题。

我在 WSO2-SI（流集成商）工作并构建一些 siddhi 应用程序。我开始需要使用 siddhi 商店中提供的 mongodb-store 扩展。我安装了扩展并使用 mongodb 配置了 @store。但似乎，我无法运行该应用程序，因为我遇到了错误com/mongodb/MongoException。有时，当我重新启动 SI 时，我看到com/mongodb/MongoSocketOpenException. 我不知道为什么会发生以及如何调试此错误。我可以在目录下看到 mongodb jar 文件{WSO2-SI-HOME}/lib/，因此安装了扩展但无法正常工作。

这是我的 siddhi 应用程序的完整代码：

添加了新行

我在服务器上测试了应用程序，发现了以下原因：

但我不知道，如何解决它。

我正在开发一个在单个节点上运行的 WSO2 si 上的 siddhi 应用程序。

数千行 json 格式的流数据，我使用 siddhi 的时间窗口和分区功能来分析数据。

但是，在前 20k 行中处理得很好，但处理率下降了。之后，当应用程序仍在运行但没有处理更多数据时，wso2 si 很快就会变为非活动状态。我检查了监视器仪表板并使用了大约 700-900mb 的堆空间，我正在使用的虚拟机应该有大约 8 GB 的堆空间。

寻求使用 wso2 的建议，将时间窗口设置为 48 小时或天是一个好习惯吗？还是分区太多影响性能？

如果是这样，有什么建议吗？

非常感谢。

我正在使用 WSO2 Streaming Integrator Tooling 来测试这个脚本：

日志是：

我的问题是，当我用新数据覆盖 csv 文件时，日志什么也不做。

我该如何解决这个问题？换句话说，如何在每次修改或覆盖时自动轮询整个文件（而不是按行）？

谢谢。