WSO2 IOTS:如何使用事件存储来存储设备历史记录
WSO2 IOTS: How to use Event Store to store device history
我想知道 WSO2 CEP
是如何工作的,Event Stream
很简单,但是 Event Store
是什么?它可以存储设备历史记录但在哪里?我正在考虑 Spark
并且它只将数据存储在内存中,对吗?如果我想在 RDMS
中存储设备历史记录,我可以做什么?谢谢
如果我简要解释 WSO2 CEP 是如何工作的,或者更确切地说,CEP 蒸汽引擎是如何工作的(它为 ITOS 提供动力),还有携带设备数据的事件流等。您可以编写查询来使用这些流,做一些 manipulations/operations 并产生另一个事件流作为输出。这将实时完成。 Siddhi 是您将用来编写这些查询的语言。 Siddhi 提供称为事件表[1] 的功能,您可以在其中将事件存储在内存或 RDBMS 表中,并在以后使用它。
事件存储是一个可以直接将传入事件保存[2] 到 RDBMS 的地方。但此数据主要用于由 Apache Spark 提供支持的批处理分析。使用事件存储,您可以存储完整的流,然后 运行 hourly/daily 对它们进行 Spark 查询以提取统计信息。当然,如果 needed.Following 参考资料有助于理解更多信息,您当然可以通过前面提到的 Siddhi 对存储在 RDBMS 中的数据执行相同的操作。
[1] https://docs.wso2.com/display/DAS300/Siddhi+Query+Language#SiddhiQueryLanguage-EventTable
[2] https://docs.wso2.com/display/DAS300/Persisting+Data+for+Batch+Analytics
https://docs.wso2.com/display/IoTS100/How+WSO2+IoT+Server+Function
https://docs.wso2.com/display/DAS300/Architecture
我想知道 WSO2 CEP
是如何工作的,Event Stream
很简单,但是 Event Store
是什么?它可以存储设备历史记录但在哪里?我正在考虑 Spark
并且它只将数据存储在内存中,对吗?如果我想在 RDMS
中存储设备历史记录,我可以做什么?谢谢
如果我简要解释 WSO2 CEP 是如何工作的,或者更确切地说,CEP 蒸汽引擎是如何工作的(它为 ITOS 提供动力),还有携带设备数据的事件流等。您可以编写查询来使用这些流,做一些 manipulations/operations 并产生另一个事件流作为输出。这将实时完成。 Siddhi 是您将用来编写这些查询的语言。 Siddhi 提供称为事件表[1] 的功能,您可以在其中将事件存储在内存或 RDBMS 表中,并在以后使用它。
事件存储是一个可以直接将传入事件保存[2] 到 RDBMS 的地方。但此数据主要用于由 Apache Spark 提供支持的批处理分析。使用事件存储,您可以存储完整的流,然后 运行 hourly/daily 对它们进行 Spark 查询以提取统计信息。当然,如果 needed.Following 参考资料有助于理解更多信息,您当然可以通过前面提到的 Siddhi 对存储在 RDBMS 中的数据执行相同的操作。
[1] https://docs.wso2.com/display/DAS300/Siddhi+Query+Language#SiddhiQueryLanguage-EventTable
[2] https://docs.wso2.com/display/DAS300/Persisting+Data+for+Batch+Analytics
https://docs.wso2.com/display/IoTS100/How+WSO2+IoT+Server+Function
https://docs.wso2.com/display/DAS300/Architecture