您可以配置數據流轉規則,將處理過的數據轉發到時序數據庫(TSDB)的中。本文以物模型數據上報Topic為例,介紹流轉消息數據的完整流程。
前提條件
已確認當前物聯網平臺實例及所在地域支持將數據轉發到時序數據庫(TSDB)。支持的地域詳細信息,請參見各地域功能說明。
已創建數據源DataSource,并添加物模型數據上報Topic。具體步驟,請參見添加待流轉的數據源。
- 已在華東2(上海)地域創建專有網絡下的TSDB實例。詳細內容,請參見時序數據庫(TSDB)文檔。重要 時序數據庫(TSDB)實例于2022年04月06日停止新購,建議您將數據流轉到時序數據庫(Lindorm)。使用方法,請參見數據轉發到時序數據庫(Lindorm)。
對于2022年04月06日(不包含)前已經購買的TSDB實例支持正常續費和升配。
背景信息
轉發的數據目的配置完成后,會自動完成以下配置,實現設備數據通過物聯網平臺的規則引擎轉發到時序數據庫(TSDB)。
- 物聯網平臺占用TSDB實例所在虛擬交換機的2個IP地址;將虛擬交換機的IPv4網段配置到TSDB實例的白名單中。
- 在TSDB實例所在的VPC網絡下創建托管安全組,安全組名稱默認以sg-nsm-開頭。
本文示例中,寫入時序數據庫的數據如下:
- timestamp:使用函數
timestamp()
獲取設備上報數據的當前時間。 - tag:使用函數
deviceName()
獲取設備名稱,寫入標簽{"deviceName":deviceName()}
。 - metric:使用JSONPath方法,獲取設備上報的物模型屬性Temperature和Humidity的值,分別寫入溫、濕度的時序數據。
限制說明
- 僅支持同地域轉發。例如:華東2(上海)的物聯網平臺實例數據只能轉發到華東2(上海)的TSDB實例中。
- 僅支持轉發到專有網絡(VPC)下的TSDB實例。
- 僅支持轉發JSON格式數據。
- 轉發的消息中,除了配置為timestamp和tag值的字段外,其他字段都將作為metric寫入時序數據庫。metric的數據類型支持數值型、字符串,其他類型會導致寫入數據庫失敗。
使用說明
目前,新版和舊版云產品流轉功能均支持將數據流轉到時序數據庫(TSDB)。舊版云產品流轉使用示例,請參見舊版:數據轉發到時序數據庫(TSDB)。
創建數據目的
- 登錄物聯網平臺控制臺。
在實例概覽頁簽的全部環境下,找到對應的實例,單擊實例卡片。
- 在左側導航欄,選擇 。
在云產品流轉頁面,單擊右上角體驗新版,進入新版功能頁面。
說明如果您已執行過此操作,再次進入云產品流轉頁面,會直接進入新版功能頁面。
單擊數據目的頁簽,然后單擊創建數據目的。
在創建數據目的對話框,輸入數據目的名稱,例如DataPurpose,按照以下參數說明,完成配置,然后單擊確定。
參數
描述
選擇操作
選擇存儲到時序數據庫(TSDB)中。
地域
與您的物聯網平臺實例所在地域一致。
TSDB實例
選擇數據轉發目的為您已創建的專有網絡(VPC)下的TSDB實例。
metric數據類型
選擇metric的數據類型。支持數值型和字符串。
更多信息,可單擊幫助按鈕查看。
角色
授權物聯網平臺將數據寫入TSDB。
配置并啟動解析器
創建解析器,例如DataParser。具體操作,請參見創建解析器。
在解析器詳情頁面,關聯數據源。
在配置向導的數據源下,單擊關聯數據源。
在彈出的對話框中,單擊數據源下拉列表,選擇已創建的數據源DataSource,單擊確定。
在解析器詳情頁面,關聯數據目的。
單擊配置向導的數據目的,然后單擊數據目的列表右上方的關聯數據目的。
在彈出的對話框中,單擊數據目的下拉列表,選擇已創建的數據目的DataPurpose,單擊確定。
在數據目的列表,查看并保存數據目的ID,例如為1000。
后續解析腳本中,需使用此處的數據目的ID。
在解析器詳情頁面,單擊解析器。
在腳本輸入框,輸入解析腳本。腳本編輯方法,請參見腳本示例。
函數參數說明,請參見函數列表。
//通過payload函數,獲取設備上報的消息內容,并按照JSON格式轉換。 var data = payload("json"); //篩選出上報的溫濕度值。 var h = data.items.Humidity.value; var t = data.items.Temperature.value; //直接流轉物模型上報數據。 writeTsdb(1000,timestamp(),"temperature", t , {"deviceName":deviceName()}); writeTsdb(1000,timestamp(),"humidity", h , {"deviceName":deviceName()});
單擊調試,根據頁面提示,選擇產品和設備,輸入Topic和Payload數據,驗證腳本可執行。
參數示例如下:
運行結果如下,表示腳本執行成功。
單擊發布。
回到云產品流轉頁面的解析器頁簽,單擊解析器DataParser對應的啟動按鈕,啟動解析器。