IoT平臺規則引擎+表格存儲OTS實現當前設備狀態存儲

背景

IoT場景中，設備往往會定時上報自己當前的運行狀態參數，供運維人員查看設備狀態。

架構方案

開發實戰

1.水泵定時上報業務消息

水泵監控場景中，每10分鐘會定時上報運行狀態到IoT平臺，具體通信Topic和payload如下：

// 定時上報運行狀態的Topic
/${productKey}/${deviceName}/user/bizHeart/post
// 對應payload結構體
{
    status: 'RUNNING', //運行狀態 RUNNING，STOP，SHUTDOWN
    speed: 3000, //當前轉速
    waterOutput: 125,//當前出水量
    workingTime: 72//工作時長 xx分鐘
}

2.表格存儲設計

創建一個數據表，以設備deviceName為主鍵，擴展信息為設備當前狀態。

3.規則引擎配置

設備上報數據後，通過規則引擎實時流轉到表格存儲中。

3.1 數據處理SQL

SELECT 
deviceName() as deviceName,
attribute('coordinate') as coordinate, 
attribute('city') as city, 
timestamp('yyyy-MM-dd HH:mm:ss') as currentTime,
status,speed,waterOutput,workingTime 
FROM 
"/a1vYwzHjT6p/+/user/bizHeart/post"

3.2 數據轉發

4.設備運行

4.1 設備基本信息，和設備標籤

4.2 設備上報的消息日誌

4.3 消息流轉日誌

4.4 表格存儲中設備信息

結束語

通過以上方案，設備狀態上報時，自動更新到表格存儲中。我們就可以提供deviceName在表格存儲中查到設備當前運行狀態。