问题标签 [wso2-das]

先介绍一下我们的用例：

实时数据分析平台。

每1s一个外部系统产品时序数据。时序数据由[id,time,value]字段组成。支持REST API搜索这些时序数据。

我们有很多（超过 100 个）独立的 CPP 程序来分析时间序列数据，这些程序会将 KPI 生成到数据库中。程序是实时计算，每个CPP程序每秒读取数据，按次进行处理，并将KPI结果发送到数据库。

我们使用的系统架构非常简单：

但系统存在问题：

1. 每一秒，外部系统都会收到一个巨大的http请求，这会导致外部系统的性能下降。

2. DB的情况与1相同

3. 我们没有合适的工具来管理 CPP 程序，我们不知道它们何时以及为什么会崩溃。我们希望在它们有任何问题时收到警报。

4. 并且缺乏合适的工具，只能一一部署启动CPP

5. 许多程序会请求相同的时间序列数据，例如程序 A 请求 [ID1, ID2, ID3, ID4]，程序 B 可能请求 [ID2, ID4, ID6, ID7]，程序 C 可能请求 [ID3, ID5,ID5 ,ID7]，所以在不同的请求中会出现大量的重复数据。

经过一番调查，我们认为 WSO2 产品是解决我们问题的最佳选择，我们改变了架构：

我们使用DAS搜索TS数据，调度数据，收集KPI结果。GREG 用于管理 CPP 程序的生命周期。

在格雷格

1. 定义新的工件类型，该类型包含 CPP 程序（.exe 或脚本）。我们想使用发布者控制台 web 发布新的 CPP 程序，管理程序生命周期（启动/停止/暂停/重置），但仍在开发中，无法完全确认可以存档

2. 我们要将 CPP 程序文件上传到 Enterprise Store，用户可以从 GREG 发布者那里订阅它

3. 监控每个 CPP 计划。

在DAS

1. 创建自定义接收器，每 30 秒从 GREG 获取 id 列表，并从外部系统获取时间序列数据

2. 创建流，它持久化事件数据

3. 创建执行计划，它使用 siddhi 重新组织每个 CPP 的时间序列数据

4. 创建 HTTP 接收器以接收来自 CPP 的 KPI 结果

5. 创建发布者以将 KPI 发送到外部数据库存储

那么我们的架构有什么问题吗？它是使用 DAS 和 GREG 的最佳方式吗？

感谢您的任何建议。

java.lang.NullPointerException at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.initializeDatabaseExecutionInfo(RDBMSEventAdapter.java:226) at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.publish(RDBMSEventAdapter .java:132) 在 org.wso2.carbon.event.output.adapter.core.internal.CarbonOutputEventAdapterService 的 org.wso2.carbon.event.output.adapter.core.internal.OutputAdapterRuntime.publish(OutputAdapterRuntime.java:69) .publish(CarbonOutputEventAdapterService.java:143) 在 org.wso2.carbon.event.publisher.core.internal.EventPublisher.process(EventPublisher.java:361) 在 org.wso2.carbon.event.publisher.core.internal.EventPublisher .sendEvent(EventPublisher.java:209) 在 org.wso2.carbon.event.publisher.core.internal.EventPublisher.consumeEvent(EventPublisher.java:275) 在 org.wso2.carbon.event。stream.core.internal.EventJunction.sendEvent(EventJunction.java:142) 在 org.wso2.carbon.event.receiver.core.internal.management.InputEventDispatcher.onEvent(InputEventDispatcher.java:27) 在 org.wso2.carbon。 event.receiver.core.internal.EventReceiver.sendEvent(EventReceiver.java:259) 在 org.wso2.carbon.event.receiver.core.internal.EventReceiver.processTypedEvent(EventReceiver.java:241) 在 org.wso2.carbon。 event.receiver.core.internal.EventReceiver$TypedEventSubscription.onEvent(EventReceiver.java:317) at org.wso2.carbon.event.input.adapter.core.internal.InputAdapterRuntime.onEvent(InputAdapterRuntime.java:110) at org. wso2.carbon.event.input.adapter.wso2event.internal.ds.WSO2EventAdapterServiceDS$1.receive(WSO2EventAdapterServiceDS.java:92) at org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81) 在 java.util.concurrent.FutureTask.run(FutureTask.java:262) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor) 的 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) .java:1145) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 在 java.lang.Thread.run(Thread.java:745)

我在 Grails 中设置并运行了一个自定义前端。这与 WSO2 用户创建和订阅以及随后的单击相关联，用户可以在其中调用已发布的 API。我还为 DAS 配置了自定义 dayabase(MySQL)。我想在我的前端保留一个图表，它将显示 API 使用情况图表。我如何获得这些信息？是否可以通过一些 REST 调用或可能直接通过查询数据库来实现？我有很大的扩展需求，因此查询可能会产生高延迟成本。

就我而言，我使用的是 wso2 api 管理器和数据分析服务器。我需要在 DAS 分析的 api manager 发布者或订阅者帐户上显示分析数据。我更喜欢参考源

在DAS方面，我可以完美地看到结果。但是从 API 管理器端看不到统计信息。只有我可以看到“数据发布已启用，生成一些流量”消息。也没有收到任何错误。请指导我如何解决这个问题。

[编辑]按照@Prabudda Sri Rahal 的回答中提到的步骤后，我得到了这个例外。

那么我该如何解决这个问题。

我正在尝试使用 WSO2 DAS 创建分析报告。谁能建议我如何将 WSO2 DAS 的工件从 dev 转移到 PROD。WSO2 DAS 有开发工具吗？

提前致谢。

我正在尝试将 WSO2 DAS 数据源从 H2 更改为 postgres。

我已在 master-datasource.xml、analytics-datasource.xml 和 metrics.xml 中配置了所有数据库更改

创建事件流时引发以下异常

请帮助解决这个问题。

谢谢你。

我使用 ESB 将 XML 消息转换为 CEP http 接收器，即 XML：

CEP 中的 http 接收器：

http接收器每次只接收第一个“事件”节点，那么如何配置接收器可以一次接收所有“事件”节点？

我尝试在 wso2 的数据分析服务器 (DAS) 中的仪表板设计器 jaggery 应用程序中创建一个新页面。为此，我在 /themes/template 中添加了一个新模板，在本例中为 delete-gadget.jag，我在 /controllers 中添加了一个同名的新控制器 delete-gadget.jag。在 /themes/template 中，我更新了 index.jag 并为 delete-gaget.jag 添加了一个新链接。单击此链接时，应用程序显示 404。

这是我的代码：

在 /controllers/delete-gadget.jag 中：

在 /themes/template/index.jag 中添加新链接：

当我单击此链接时：

My scenario,

I have some transaction details in Mysql DB. I use WSO2 ESB server and push these data into WSO2 DAS server(persisted the data in H2 DB with primary key and index). The data are loaded to the DAS server successfully but the problem I face is, I see an ERROR in my DAS console continuously after every three seconds. The error is given below.

I am not sure why this is happening. Please help and thanks in advance.

I use independent wso2 API manager 1.10.0 and wso2 DAS 3.0.0 on AWS ec2 to gather statistics of my API usage and I use postgresql to be external RDBMS to store summary data.

APIM configurations on Admin-Dashboard

Event Receiver Configurations :

tcp://DAS-IP:7611

Data Analyzer Configurations :

https://DAS-IP:9443

Statistics Summary Datasource :

My-postgresql-url

APIM configuration in api-manager.xml

Disable rest client and enable RDBMS client

DAS configuration

Set datasource WSO2AM_STATS_DB in master-datasources.xml

Scenario

1. Login to APIM publisher

2. Deploy sample API

3. Go to APIM store

4. Subscribe sample API

5. Go to APIM publisher

6. Click statistics > API usage

7. Only show example statistics page.

APIM Logs

DAS Logs

DAS WSO2_STATS_DB status

From DAS dashboard > configure > data sources,I've checked the status of all DB is active and tested connection is healthy.

I don't know if WSO2AM_STATS_DB doesn't support postgresql or my configuration gets something wrong.

thanks