问题标签 [wso2sp]

我正在尝试部署一个 siddhi 应用程序。

我已将 .siddhi 应用程序复制到 /wso2/worker/deployment/siddhi-files。

当我运行 worker.sh 文件时，出现以下错误。

目前尚不清楚“Siddhi App 内容”的修改位置。你能帮我解决这个问题吗？

我正在尝试运行WSO2 Siddhi 文档中给出的示例代码。

我已经复制了那里给出的内容。

在 Event Simulator 选项卡中，我传递了示例中给出的值，即：时间戳字段中的 154467847759 和 creditCardNo(STRING) 中的 5555555555554444。

这是即将到来的错误。

我正在尝试根据此处的示例在 Siddhi 中使用 http-request (source) 和 http-response (sink) 发送同步请求。

我有一个 API，我可以使用 curl 命令来访问它。这是我的 curl 命令和输出。

我正在尝试使用 Siddhi 做类似的事情。

这是我的代码。

我在@sink 行中遇到的错误是：

我在这里缺少什么吗？

我正在尝试将满足某些过滤器的事件存储到弹性索引中，但是当我设置存储表时，它说它无法为该表创建索引。

我已经在产品的 4.3.0 和 4.4.0 版本中对此进行了测试，但都没有奏效。

整个日志是下一个：

我的要求是在 WSO2 流处理器中运行 siddhi 应用程序，以使用没有编辑器的 docker 容器进行生产设置。我想在启动工作容器时使用 docker run 命令部署和运行 siddhi 应用程序。

我们不希望将编辑器设置作为生产环境的一部分，请告诉我们如何实现？

我正在尝试运行流处理器中的示例中存在的 RScriptSample。

我已按照此处给出的步骤进行操作。

我已经安装了 R 和 rJava，并相应地设置了 R_HOME 和 JRI_HOME。

代码无法编译。我在最后一行收到此错误。

我究竟做错了什么？

我使用事件模拟器在编辑器中获得了一个功能性 siddhi 文件，但我无法使用 tcp 源收集数据，是否有某种模式需要匹配才能被接收？

我在该软件的最后两个版本中尝试过，当我读到它的最后一个版本时，它们将更改几乎所有的 tcp 协议，我认为我应该能够接收某种数据，我在tcpdump 但不在活动中

它应该接收事件并将其保存在内存中以供处理

我目前有一个流，具有 1 个包含 Json 事件的字符串属性。

这个流接收不同的事件，我想应用 Json 路径表达式，以便我可以在过滤器和函数上使用这些属性。

JsonPath 提取器在过滤器和选择器上就像一个魅力，不幸的是，我无法将它们用于“分组依据”部分。我实际上是在手动添加了 siddhi-execution-json 扩展的嵌入式 Siddhi 应用程序中执行此操作，但为了讨论，以便每个人都可以轻松检查和测试它，我将粘贴一个适用于 WSO2 流处理器的示例应用程序。目标看起来像以下应用程序：

它可以接受以下事件：

{"myField": "my_value"}

但是，此查询将引发错误：

Cannot find attribute type as 'myField' does not exist in 'JsonStream'; define stream JsonStream(json string)

我还尝试在“Group by”中直接使用 Json 提取器：

group by json:getString(json, '$.myField') as myField having count > 1

但是现在的错误是：

mismatched input ':' expecting {',', ORDER, LIMIT, OFFSET, HAVING, INSERT, DELETE, UPDATE, RETURN, OUTPUT}

这似乎不希望在这里使用扩展

我只是想知道，是否可以按输入流中未直接定义的属性进行分组。在这种情况下，是从 JSON 对象中提取的字段，但它可以是生成另一个属性的任何其他函数。

我也在使用来自 Maven 中央存储库的版本

• 悉地语： io.siddhi :siddhi-core:5.0.1
• siddhi-execution-json：io.siddhi.extension.execution.json:siddhi-execution-json:2.0.1

（编辑）澄清

目标是使用未直接在 Stream 中定义的属性，用于Group By.

原因是，我目前有一个嵌入式应用程序，它定义了来自外部源的整套输入流，格式为 JSON，还有一组输出流在查询匹配时通知外部组件。这个应用程序允许用户在这组预定义的 Streams 上创建自定义查询，但他们不能自己创建 Streams。

非常感谢！

我得到了一个 siddhi 的工作代码，我想知道它是否可以使用没有封闭元素的 json 格式输出事件。

我试着把一个空的 enclosing.element 和 $. ，但它们似乎都不起作用。

我得到了以下结果

并且期望的输出是

我正在尝试添加到我的 cassandra 数据库的连接。

如示例中所示，我添加了此定义：

在编辑器中，我得到一个红十字，如下图所示。我错过了工人身上的 cassandra 司机吗？如果是，如何将其添加到 docker 映像中？或者我做错了什么？