Thingsboard处理来自设备的数据并将其重新注入新的遥测数据

Posted 2021-05-04

我正在开发一个物联网项目，该项目涉及一个传感器将其值传输到物联网平台。我目前正在测试的平台之一是Thingsboard，它是开源的，我发现它很容易管理。

我的传感器正在向Thingsboard传输活动能量指数。使用这些值，我想计算并在小部件上显示有功功率的值（= k * [ActiveEnergy（n） - ActiveEnergy（n-1）/ Time（n）-Time（n-1）]） 。这基本上意味着我想访问历史数据，使用这些数据生成新数据并将其注入我的设备。

Thingsboard使用Cassandra数据库来保存历史值。我的问题的一个替代方案可能是找到一种通过Web API与数据库通信的方法，例如，使用其访问令牌在我的设备上进行处理并通过MQTT或HTTP发回有效功率。这可能吗？有没有更好的替代我的问题？

答案

有几种选择如何实现（基于系统的层或组件）：

1）仅可视化层。可能是最简单的一个。可以选择应用后处理功能。该功能具有以下签名：

功能（时间，价值，prevValue）

请注意，缺少prevTime，但我们可能会在将来的版本中添加它。

post processing function

2）数据处理层。例如，使用像Apache Spark这样的高级分析框架，使用滑动时间窗口对数据进行后处理。请参阅我们的integration article。