如何将java类中的数据推送到Wso2数据仓库

Question

是否有任何文档或分步过程指导我们如何使用java从WS02类对象中提取数据，并使用WS02仪表板显示使用这些数据的报告。

任何帮助都将不胜感激。

Answer 1

首先，您可以通过指定属性来创建事件流，并指出需要持久化的属性是什么。

在创建事件流时，您可以使用Thrift、Soap、Http、Mqtt、JMS、Kafka和Web套接字等协议。您可以编写一个简单的Java应用程序，将数据发布到您选择的消息格式协议上创建的DAS接收器。例如，如果创建SOAP接收器，则可以使用soap消息格式的数据；如果创建HTTP接收器，则可以使用JSON格式。

您可以创建仪表板和小工具来可视化由持久流3创建的事件表。请注意，此事件表包含WSO2 DAS接收的所有事件，您可以使用spark SQL4处理这些数据，并创建可在分析仪表板中使用的多个流。

1

2

3

4

Answer 2

你的问题的主题和主体是矛盾的。主体说推数据，主体说拉数据。

如果推送数据是您想要实现的目标，您可以参考https://docs.wso2.com/pages/viewpage.action?pageId=45952633，这使用了一个节俭客户端来将数据推送到DAS。

如何分析原始数据，请参考https://docs.wso2.com/display/DAS300/Analyzing+Data。您可以编写用于分析的spark脚本。

最后，您可以通过https://docs.wso2.com/display/DAS300/Communicating+Results了解如何分析数据。您可以使用DAS 3.0.0提供的REST API从DAS中提取数据。