问题标签 [wso2sp]

我希望禁用收集 WSO2 EI 中所有序列和介体的统计信息。我仍然想收集有关服务调用的统计信息，但要丢弃有关这些服务中包含的序列和中介的不需要的统计信息（这是很多不必要的数据）。

我知道除了启用/禁用特定服务的统计信息外，您还可以禁用特定序列的统计信息，这也意味着不收集有关这些序列中包含的中介的统计信息。然而，在我们的项目中，一些服务只包含中介而不包含序列。

到目前为止，我们已经尝试将布尔值添加到synapse.properties文件中

并在org.apache.synapse.aspects.flow.statistics.collectors.OpenEventCollector.java 文件中编辑reportEntryEvent()和 reportChildEntryEvent()方法。例如，如果传入的componentType是 mediator，我会退出reportChildEntryEvent()方法，假设它会停止统计收集过程。然而，这个逻辑似乎不正确，因为我仍然在我的流处理器中收到中介统计信息。

这种统计处理可能也在其他地方进行管理，但我实际上很难看到我应该在wso2-synapse代码中的具体位置和内容进行编辑以实现此行为。

感谢您的回复。

我如何配置@sink 来调用基于soap 的web api？我在哪里可以指定肥皂动作？我在网上找到的参考不能正常工作？

我正在尝试通过 siddhi 应用程序连接 mysql 服务器，并按照以下文档链接进行设置。 https://docs.wso2.com/display/SP430/Integrating+Datastores

但是当我运行 siddhi 应用程序时，我收到以下错误，

下面是我在 WSO2 流处理器工作室中创建的 siddhi 应用程序，

下面是我在编辑器deployment.yaml中定义的mysql配置

在放入 /lib 目录之前，我尝试将 mysql 驱动程序转换为 OSGI（使用 jartobundle.sh）：

如果我在设置中做错任何事情，请帮助我解决错误并纠正我。

谢谢！！

我正在运行WSO2 Stream Processor 4.3.0，我创建了一个 siddhi 应用程序，我想在生产中的工作人员上部署和运行这个应用程序。"wso2-sp"我在文件中使用类型运行 WSO2 SP 工作人员配置deployment.yml文件。如何让工作人员运行我的自定义 siddhi 应用程序？

环境：WSO2 流处理器 4.3.0

假设我有两个非常简单的流：

实时交付新创建的请求（未完成）的流（t1）

实时完成请求时出现 requestsIds 的流 (t2)

保证 t2 总是 > t1

如何实现一个 SiddhiQL 语句来识别出现在RequestStream (event1)中并且在event1 过去 5 分钟后没有出现在FulfilmentStream (event2)中的 requestIds？

基于 Tishan 的工作 Siddhi App 答案：

我正在尝试使用 WSO2SP-4.3.0 作为 WSO2AM-2.6.0 和 WSO2EI-6.4.0（集成器）的分析。我在这里找到的唯一参考是https://docs.wso2.com/display/SP430/Analytics+Solutions

设置端口和解决方案图：

运行 SP 的 worker 和仪表板

似乎未加载 loganalyzer 的流定义，worker 抛出以下异常：

我还没有找到 loganalyzer流定义的来源（即使在原始的 ws2am-analytics-2.6.0 包中）。

任何帮助表示赞赏（或者我应该从 APIM 禁用 DAS_AGENT）？

从Siddhi-io-http阅读我无法理解如何绕过 ssl 认证错误（即：过期或自签名）。

有一个名为ssl.verify.client的参数，但没有关于它接受哪些值的信息。

有谁知道该怎么做？

完全例外

我有多个查询将结果输出到同一个输出流。

查看输出流中的查询结果，我想将结果绑定到触发结果的查询。

有没有办法让我使用触发输出的查询的 ID/名称来丰富查询结果？

我已经在服务器上安装了 WSO2 Api Manager，我正在尝试添加 Analytics。问题是当我在 WSO2 Api Manager 中更改管理员密码时，我的 Analytics 实例保留了他的旧密码。因此，Api Manager 无法再访问 Analytics。

如何更改 API-M Analytics 的密码并创建其他用户？

谢谢 ！

编辑：APIM 版本 2.6.0 和 APIM-Analytics 2.6.0

编辑deployment.yaml后

我在 deployment.yaml 中添加了 auth 段，并在 api-manager.xml（Analytics 段、StreamprocessorPassword 属性和 StreamProcessorRestApiPassword 属性）中更改密码以与我在 deployment.yaml 中的密码匹配。

我还在 log4j.properties（DAS_AGENT 和 LOGEVENT）中更改了密码。API Manager 一直说我的用户名或密码错误（用户名没有改变）

API 管理器日志

TID：[-1] [] [2018-11-27 15:51:41,481] 错误 {org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker} - 尝试连接到端点时出错。无法为 ssl://10.16.243.135:9711 借用客户端。{org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker} org.wso2.carbon.databridge.agent.exception.DataEndpointLoginException：无法为 ssl://10.16.243.135:9711 借用客户端。在 org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.connect(DataEndpointConnectionWorker.java:134) 在 org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.run(DataEndpointConnectionWorker.java:59) 在 java.util .concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent。

API Manager 分析工作人员日志

错误 {org.wso2.carbon.databridge.core.internal.queue.QueueWorker} - 丢弃格式错误的事件发送 org.wso2.carbon.databridge.core.exception.EventConversionException：转换 loganalyzer:1.0.0 的事件捆绑时出错org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.toEventList(ThriftEventConverter.java: org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:188: 90) 在 org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:72) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util .concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 在 java.util.concurrent。java.lang.Thread.run(Thread.java:748) 处的 ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 原因：org.wso2.carbon.databridge.core.exception.EventConversionException：没有 StreamDefinition for streamId loganalyzer： 1.0.0 存在于 org.wso2.carbon.databridge.receiver.thrift.converter.ThriftEventConverter.createEventList(ThriftEventConverter.java:171) 的缓存中 ... 还有 7 个

我需要将事件发送到 http 端点。如果我做类似的事情：

我的网络服务中有以下消息： [{f_id:1}, {f_id:2}, ...] 而不是带有预期消息的 N 请求，例如{f_id:N}.

我找到了解决方案：

是正确的吗？还有其他方法可以解决这个问题吗？