问题标签 [wso2sp]

我尝试在同一台机器上运行 Worker 和 dashbord。第一个工具正常运行，但是当我启动第二个工具时，出现了错误：

[2018-03-07 09:59:43,546] INFO {org.wso2.msf4j.internal.websocket.EndpointsRegistryImpl} - 已注册端点：/server-stats/{type} [2018-03-07 09:59:43,636] INFO {org.wso2.carbon.data.provider.DataProviderAPI} - 数据提供者服务组件已激活 [2018-03-07 09:59:44,909] INFO {org.wso2.msf4j.internal.websocket.WebSocketServerSC} - 所有必需WebSocket 服务组件的功能可用。[2018-03-07 09:59:45,049] INFO {org.wso2.msf4j.internal.MicroservicesServerSC} - 所有微服务都可用 [2018-03-07 09:59:45,346] INFO {org.wso2.transport.http .netty.listener.ServerConnectorBootstrap$HTTPServerConnector} - HTTP(S) 接口从主机 0.0.0.0 和端口 9643 [2018-03-07 09:59:45,939] INFO {org.wso2.carbon.metrics.core.config.模型。

你能给些建议么？

谢谢。

我在 wso2 SP 上有输入流作为 wso2event，它包含时间戳和有效负载。有效载荷为 xml 格式。如何将此有效负载解析为变量？我看到这个文档https://wso2-extensions.github.io/siddhi-map-xml/api/4.0.11/但我不知道，如何将传入的 wso2event 获取到 sourcemapper，然后将其解析为变量？

我有一个场景，如果查询的一部分匹配一个事件，我想从数据存储中获取一些其他事件来测试查询的其余部分

例如。“如果 JANE DOE 从我的商店购买，她在过去 3 年里是否还买了其他东西”之类的东西。

Flink、Storm 或 WSO2 是否提供对此类复杂事件处理的支持？

我尝试通过siddhi-io-jms 扩展将事件从 WSO2 SP 发送到 activeMQ ，但出现以下错误。连接到 JMS 提供程序时出错。获取初始上下文时出现 NamingException。 我已经按照这个文档支持 jms 传输https://docs.wso2.com/display/SP400/Supporting+Different+Transports，将所有必要的 jar 文件放到 lib 中，我也在 siddhi 应用程序factory.initial中正确设置了@sink和provider.url是正确的。任何想法，为什么SP无法连接到jms？

可以在 WSO2 流处理器 4.0 上部署的 siddhi 应用程序的数量是否有任何限制？哪些因素决定了应用数量的限制？

我有一个来自 ActiveMQ 的源数据，我遇到的问题是这些数据没有固定的结构，因此，当我定义流时它会引发不兼容的数据类型错误，有没有办法通过某些条件来调节源流?

提前致谢。

按照 WSO2 SP 4.1.0 文档中提供的示例，我正在尝试运行一个示例，从 csv 文件中读取数据，根据数据预测一些结果，并将预测结果导出到 csv 文件。

到目前为止，对 csv 文件的读取和写入工作正常，但是当我添加 PMML 预测部分时，我无法运行文件，得到错误“ERROR {org.wso2.extension.siddhi.gpl.execution.pmml.util .PMMLUtil} - 无法解组 pmml 定义：null”。

该模型是一个随机森林回归器，有 15 棵树，max_depth=15 用 sklearn 训练，并使用 sklearn2pmml 0.35.1 Python 库导出。我已经将“siddhi-gpl-execution-pmml-4.0.13.jar”文件复制到“{wso2_4.0.0 install dir}/lib”。

我想知道使用 sklearn2pmml 导出的 PMML 定义（模型遵循 PMML 4.3 定义）与 WSO2 SP 接受的 PMML 定义之间是否存在版本不匹配。

编辑：

错误现在没有显示，我附上了在 Firefox 上运行的 WSO2 SP 编辑器的图像，您可以在其中看到查询有错误，但错误框是空的！（这只发生在这个错误中）。

链接到屏幕截图。请注意，来自错误的消息框是空的！

编辑2：

我已经尝试过在No Extension Exists for pmml:predict WSO2 Stream Processor (siddhi-gpl-execution-pmml-4.0.11.jar) 中提出的 .jar 以及 siddhi-gpl-execution-pmml-4.0.13.jar。两者都给出相同的错误（错误消息框中没有任何解释）。

我在 HA 集群的不同服务器上有两个 SP 节点。我需要使用分发接收器，因为两个节点都消耗来自 EI 的事件，但被动节点将这些事件保存在队列中。活动节点向数据库发送事件。我在 tcp sink 中使用 @distribution 注释将事件从被动节点分发到主动节点。此外，我将 forcePublish 属性设置为 true，如文档中所述。https://docs.wso2.com/display/SP410/Minimum+High+Availability+%28HA%29+Deployment 现在我有两个问题。

1. 当其中一个节点关闭时，活动节点仍在丢弃事件并出现此错误：Dropping event at Sink 'tcp' at 'DistributionStream' 因为它仍在尝试重新连接！ 如果它在 HA 中运行并且一个节点仍处于启动状态，为什么会出现此错误？

2.当两个节点都在运行时，被动节点仍然不向主动节点分发事件，所以只有一半的事件被发送到DB，另一半仍然保留在被动节点上，只有当被动节点状态变为主动时才会发布.

经销商

执行者

两个节点上的 Deployment.yml

任何想法，这些问题的原因是什么？

}

此代码无法从 rabbitmq 检索事件消息。

我可以看到到 rabbitmq 仪表板的连接和通道，所有发布到交换的消息都被传递到其他绑定队列。

我计划使用历史事件跟踪（存储在 JSON 中，并为每个事件记录我自己的事件时间戳）来调试我刚刚创建的 Siddhi 流查询。我的直播开始于：

从 MyInputEventStream#window.externalTime(my_own_timestamp, 10 min) 选择 some_fields 插入 MyOutpuStream；

我将从痕迹中一一输入我的事件。

假设事件 1 到达指定的 my_own_timestamp = 1528905600000，即太平洋标准时间 6 月 13 日上午 9 点。而事件 2 在 11 分钟后到达，my_own_timestamp = 1528906260000。我相信我会在上午 9:10 在 MyOutpuStream 获得输出，因为time_stamp(e2) - time_stamp(e1) > 10 min，并且e2会在windows过去后触发系统。

现在假定事件 1 到达 my_own_timestamp = 1528905600000，即上午 9:00。但在接下来的 2 小时内不会有任何事件发生。我是否仍然在上午 9:10 获得输出，因为实际上，窗口时间应该在上午 9:10 到期，与下一个事件何时到达无关？但似乎在这种情况下，Siddhi 的内部计时系统将不得不合并我的事件输入的时间戳，然后根据运行 Siddhi 的进程的时钟系统设置事件的到期时间。这个对吗？你能帮忙澄清一下吗？