问题标签 [wso2sp]

我使用以下 Dockerfile为 WSO2 流处理器编辑器配置文件实现了一个示例 Docker 映像：

在构建上述 Docker 映像时，您将提供 Oracle JDK 和WSO2 流处理器分布（filesDocker 构建上下文中的目录必须包含这些分布）。

我已经运行了创建的 Docker 映像

并且没有端口

转发，但我无法从端口 9390 访问编辑器 UI。如下面的日志所示，我们应该能够通过 URL 访问服务

或者通过

我也通过日志发现服务器已经启动成功了，如下：

是什么导致无法访问正在运行的服务？任何建议和想法都将受到高度赞赏。

我打算将 Siddhi 用于规则评估引擎

我有以下情况要满足

当用户创建条件时需要一种方法来持久化它们，当运行 siddhi 的节点由于某些原因重新启动时可以使用该方法

我需要一个通用接口来表示不特定于 siddhi 的外行语言的规则。因为用户应该能够在不知道 siddhi 的情况下配置条件

对此的任何输入都会有很大帮助

我有一个在 Android 上运行的 siddhi cep 应用程序。现在我想通过套接字连接将事件模拟器中的事件从流处理编辑器发送到 android 应用程序。到目前为止，我已经成功地制作了监听我制作的 python 客户端模拟器的 android 服务器套接字。但是为了简化这个过程，我是否可以使用事件模拟器将事件发送到 android siddhi 应用程序？

我想知道是否可以更改一些配置，例如事件模拟器将事件发送到 android 套接字，所以我查看了deployment.yaml文件中的设置

但发送配置是为HTTP

提前致谢。如果您需要更多详细信息，请告诉我

编辑 1

我实际上找到了一种方法来做到这一点，但它有一些问题。所以基本上我将输出接收器重定向event generator到端口，以便接收器具有所有数据流。的代码Stream Processor Studio editor是

它将流作为文本发送到需要首先启动的python服务器，其代码是

最初，我json从模拟器发送数据，但pickle.loads没有json.loads工作。但文本的问题是数据显示为

如何删除这些额外的数据？

我正在尝试在 WSO2 流处理器上使用两个源（都是文件）配置一个 Siddhi 应用程序，但这不起作用（一个源工作正常）。但是，即使我将应用程序拆分为 Siddhi 应用程序也不起作用。两种情况下的日志如下：

任何人都可以提出如何克服这个问题的想法？

谢谢。

我正在按照 WSO2 Stream Processor Studio 教程来练习 Siddhi。到目前为止，我已经设法解决了教程中包含的所有错误；但是，我被困在第 12 个教程“进行实时预测”上。

Siddhi 应用程序是

在从 SugarSyrupDataStream 开始的行中，我收到一条错误消息“pmml:predict 没有扩展存在”

WSO2 Siddhi Gpl Execution Pmml文档说将组件jar文件复制到目录<STREAM_PROCESSOR_HOME>/lib。问题是，tar 或 zip 文件都没有 jar 文件。它们都包含 pom.xml 文件，并且我找到的文档都没有告诉我在哪里部署扩展。

我尝试将它部署在上面引用的库目录以及功能和插件目录中。我每次都停止并重新启动 Stream Processor Studio 服务（editor.sh）。我总是收到相同的错误消息。

我已经在 Ubuntu 16.04.3 LTS 上安装了 WSO2 产品，并通过 Firefox 浏览器访问流处理器工作室。

我需要知道如何通过事件发布者从 Enteprise Integrator 发布统计信息到流处理器。

我在我的 EI 上有以下事件发布者的实现

在流处理器上，我有简单的 siddhi 应用程序用于接收数据并将它们打印到日志中，如下所示

此外，我已将用于发布统计信息的所有配置设置为我的代理服务的“启用统计信息”和“启用跟踪”。当我调用我的服务时，eventPublisher 将 wso2event 发送到 SP，这工作正常。但在 SP 方面，SP 处理错误“没有 StreamDefinition for streamId org.wso2.esb.analytics.stream.FlowEntry:1.0.0 存在于缓存中”

我知道，这个问题出在 siddhi 应用程序中，我定义流“FlowEntry”而不是“org.wso2.esb.analytics.stream.FlowEntry”，但 siddhi 语言不支持像 '.' 这样的字符。在流名称中。

所以我尝试在 EI 站点上更改流名称，仅将 eventPublisher 中的 streamName 更改为“FlowEntry”，我还更改了 eventstream 文件夹内 json 文件中的 streamName，但现在当我调用我的服务时，EI 不会向 SP 发送任何事件。

有人知道如何将 org.wso2.esb.analytics.stream.FlowEntry 流发布到 SP，然后由 siddhi 处理吗？

我正在尝试使用 WSO2 流处理器上的 siddhi 应用程序解压缩传入事件。在早期版本（例如 DAS）上，有 siddhi 扩展 esbAnalytics:decompress，但如果我在 SP 中使用此扩展，则会出现错误“esbAnalytics:decompress 不存在扩展”

有什么方法可以在 SP 上使用 esbAnalytics:decompress 或如何解压缩传入的 flowEntry 事件？提前致谢。

我正在使用流处理器接收事件，我需要知道，有什么方法可以检查某些事件是否在窗口中的指定时间内到达？假设我们要检查，该事件每 5 分钟到达一次。如果不是，我们需要发布警报。Siddhi 4.0 有任何功能用于此目的吗？我的想法是在时间窗口中计算相同的事件，然后等于这个计数，但不知道这是否是处理这个问题的最佳方法。

我对流处理器有点困惑。我以前使用过 CEP，现在我使用的是流处理器。

如果我没记错的话，数据分析服务器、CEP 和机器学习器合并到流处理器中，是真的吗？

因为我发现了一些不一致的地方，例如 SP 不能直接在仪表板中发布，而 CEP 可以。所以，我的问题是，CEP 和 ML 中的所有 feutures 都将在 SP 中流动吗？

I have the below query in Siddhi (WSO2 Stream Processor) where I am trying to get the final sum by county when I send stream of 10 events (4 events for ABC, 6 events for CDE). But, with the below query I get all the 10 records with sum of the previous event in the table (total I see 10 records in the table).

My expected output should be as below:

Please help me to get the final entry in the table instead all the 10 entries.

Siddhi Query:

Thank you, Divya