wso2 - 如何将数据从 java 类推送到 Wso2 DAS

Question

是否有任何文档或分步过程指导我们如何使用 WS02 DAS 从 Java 类对象中提取数据并使用 WS02 Dashboards 使用此数据显示报告。

任何帮助将非常感激。

Answer 1

首先，您可以通过指定属性来创建事件流，并提及您需要保留哪些属性。当事件到达流时，这些将存储在事件表 [1] 中。

然后，您可以为该事件流 [2] 创建一个事件接收器。创建事件流时，您可以使用 Thrift、Soap、Http、Mqtt、JMS、Kafka 和 Web 套接字等协议。您可以编写一个简单的 Java 应用程序来将数据发布到您根据您选择的消息格式协议创建的 DAS Receiver。例如，如果您创建 SOAP 接收器，则可以使用肥皂消息格式的数据，并且如果您创建 HTTP 接收器，则可以使用 JSON 格式。

您可以创建仪表板和小工具来可视化由持久流创建的事件表 [3]。请注意，此事件表包含 WSO2 DAS 收到的所有事件，您可以使用 spark SQL [4] 处理这些数据并创建几个可在 Analytics Dashboard 中使用的流。

[1] https://docs.wso2.com/display/DAS300/Understanding+Event+Streams+and+Event+Tables

[2] https://docs.wso2.com/display/DAS300/Configuring+Event+Receivers

[3] https://docs.wso2.com/display/DAS300/Analytics+Dashboard

[4] https://docs.wso2.com/display/DAS300/Batch+Analytics+Using+Spark+SQL

Answer 2

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

如果推送数据是你想要实现的，可以参考https://docs.wso2.com/pages/viewpage.action?pageId=45952633这个使用thrift客户端推送数据到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 中提取数据。