工作原理

云產(chǎn)品流轉將設備的Topic消息轉發(fā)到PolarDB MySQL版集群下數(shù)據(jù)庫的數(shù)據(jù)表中存儲，使用PolarDB MySQL版的數(shù)據(jù)庫服務。詳細內(nèi)容，請參見PolarDB MySQL版。

在上圖中：

• 數(shù)據(jù)源：支持的Topic類型消息，請參見數(shù)據(jù)格式（非云網(wǎng)關產(chǎn)品和設備）、自定義Topic（MQTT云網(wǎng)關）、消息轉發(fā)Topic（GB/T 32960云網(wǎng)關）、消息轉發(fā)Topic（JT/T 808云網(wǎng)關）、消息轉發(fā)Topic（SL 651云網(wǎng)關）。

• 數(shù)據(jù)目的：創(chuàng)建的專有網(wǎng)絡下PolarDB MySQL版集群中數(shù)據(jù)庫下的數(shù)據(jù)表，用于接收設備數(shù)據(jù)。

• 解析器腳本：配置通過數(shù)據(jù)流轉函數(shù)writePolarDB(destinationId, data)將Topic數(shù)據(jù)轉發(fā)到PolarDB MySQL版數(shù)據(jù)表。

  data僅支持Map類型數(shù)據(jù)，其中鍵（Key）值對應數(shù)據(jù)庫表列名，值（Value）對應列值。函數(shù)詳細說明，請參見函數(shù)列表。

應用場景

對設備存儲數(shù)據(jù)庫有如下要求的物聯(lián)網(wǎng)應用場景：

• 大中型企業(yè)相關設備的生產(chǎn)數(shù)據(jù)庫。

• 對設備數(shù)據(jù)安全性要求非常高的核心數(shù)據(jù)庫。

使用限制

• 物聯(lián)網(wǎng)平臺實例及所在地域支持將數(shù)據(jù)轉發(fā)到云原生數(shù)據(jù)庫PolarDB MySQL版。支持的地域詳細信息，請參見各地域功能說明。

• 僅支持同地域轉發(fā)。例如：華東2（上海）的物聯(lián)網(wǎng)平臺實例數(shù)據(jù)只能轉發(fā)到華東2（上海）的PolarDB數(shù)據(jù)表中。

• 僅支持轉發(fā)到專有網(wǎng)絡VPC下的PolarDB MySQL版集群中。

• 僅支持PolarDB的MySQL 5.6、MySQL 5.7、MySQL 8.0.1和MySQL 8.0.2四種引擎類型。

• 僅新版云產(chǎn)品流轉功能支持將數(shù)據(jù)流轉到云原生數(shù)據(jù)庫PolarDB MySQL版中。

• 物聯(lián)網(wǎng)平臺實例下設備消息轉發(fā)的更多使用限制，請參見使用限制。

前提條件

• 已創(chuàng)建數(shù)據(jù)源。具體步驟，請參見添加待流轉的數(shù)據(jù)源。

  本文以物模型數(shù)據(jù)上報Topic為例，創(chuàng)建數(shù)據(jù)源DataSource并添加物模型數(shù)據(jù)上報Topic。

• 已在您的物聯(lián)網(wǎng)平臺實例所在地域，創(chuàng)建專有網(wǎng)絡下的PolarDB MySQL版集群，并創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)表，以及創(chuàng)建管理數(shù)據(jù)庫的賬號和密碼。PolarDB MySQL實例的使用方法，請參見快速入門。

背景信息

轉發(fā)的數(shù)據(jù)目的配置完成后，會自動完成以下配置，實現(xiàn)設備數(shù)據(jù)通過物聯(lián)網(wǎng)平臺的消息轉發(fā)功能流轉到云原生數(shù)據(jù)庫PolarDB MySQL版。

• 物聯(lián)網(wǎng)平臺占用PolarDB MySQL版集群所在虛擬交換機的2個IP地址；將虛擬交換機的IPv4網(wǎng)段配置到PolarDB MySQL版集群的白名單中。

• 在PolarDB MySQL版集群所在的VPC網(wǎng)絡下創(chuàng)建托管安全組，安全組名稱默認以sg-nsm-開頭。

創(chuàng)建數(shù)據(jù)目的

1. 登錄物聯(lián)網(wǎng)平臺控制臺。

2. 在實例概覽頁簽的全部環(huán)境下，找到對應的實例，單擊實例卡片。

3. 在左側導航欄，選擇消息轉發(fā) > 云產(chǎn)品流轉。

4. 在云產(chǎn)品流轉頁面，單擊右上角體驗新版，進入新版功能頁面。

   說明

   如果您已執(zhí)行過此操作，再次進入云產(chǎn)品流轉頁面，會直接進入新版功能頁面。

5. 單擊數(shù)據(jù)目的頁簽，然后單擊創(chuàng)建數(shù)據(jù)目的。

6. 在創(chuàng)建數(shù)據(jù)目的對話框，輸入數(shù)據(jù)目的名稱，例如DataPurpose，按照以下參數(shù)說明，完成配置，然后單擊確定。

   參數(shù)	描述
   選擇操作	選擇存儲到云原生數(shù)據(jù)庫（PolarDB MySQL版）中。
   授權	單擊授權，系統(tǒng)創(chuàng)建角色和授權策略，授權物聯(lián)網(wǎng)平臺將數(shù)據(jù)寫入PolarDB MySQL版數(shù)據(jù)表。詳細說明，請參見數(shù)據(jù)轉發(fā)到云原生數(shù)據(jù)庫PolarDB MySQL版的服務關聯(lián)角色。 說明 若已授權，忽略此操作。
   地域	固定與您的物聯(lián)網(wǎng)平臺實例所在地域一致。
   PolarDB集群	選擇數(shù)據(jù)轉發(fā)目的為您已創(chuàng)建的專有網(wǎng)絡（VPC）下的PolarDB集群。 您可單擊創(chuàng)建集群，新增PolarDB MySQL版集群。具體操作，請參見購買集群。
   數(shù)據(jù)庫	選擇PolarDB MySQL版集群下接收數(shù)據(jù)的目標數(shù)據(jù)庫名稱。 創(chuàng)建數(shù)據(jù)庫的具體操作，請參見創(chuàng)建數(shù)據(jù)庫。
   賬號	輸入管理數(shù)據(jù)庫的賬號和密碼。賬號應具有該數(shù)據(jù)庫的讀寫權限，否則消息轉發(fā)無法將數(shù)據(jù)寫入PolarDB MySQL版數(shù)據(jù)庫。 數(shù)據(jù)庫管理賬號和密碼說明，請參見創(chuàng)建和管理數(shù)據(jù)庫賬號。
   密碼
   表名	輸入目標數(shù)據(jù)庫下接收數(shù)據(jù)的數(shù)據(jù)表名稱。消息轉發(fā)會把數(shù)據(jù)寫入這張表中。

配置并啟動解析器

1. 創(chuàng)建解析器，例如DataParser。具體操作，請參見創(chuàng)建解析器。

2. 在解析器詳情頁面，關聯(lián)數(shù)據(jù)源。

   1. 在配置向導的數(shù)據(jù)源下，單擊關聯(lián)數(shù)據(jù)源。

   2. 在彈出的對話框中，單擊數(shù)據(jù)源下拉列表，選擇已創(chuàng)建的數(shù)據(jù)源DataSource，單擊確定。

3. 在解析器詳情頁面，關聯(lián)數(shù)據(jù)目的。

   1. 單擊配置向導的數(shù)據(jù)目的，然后單擊數(shù)據(jù)目的列表右上方的關聯(lián)數(shù)據(jù)目的。

   2. 在彈出的對話框中，單擊數(shù)據(jù)目的下拉列表，選擇已創(chuàng)建的數(shù)據(jù)目的DataPurpose，單擊確定。

   3. 在數(shù)據(jù)目的列表，查看并保存數(shù)據(jù)目的ID，例如為1000。

      后續(xù)解析腳本中，需使用此處的數(shù)據(jù)目的ID。

4. 在解析器詳情頁面，單擊解析器。

5. 在腳本輸入框，輸入如下解析腳本。

   腳本編輯方法，請參見腳本示例。函數(shù)參數(shù)說明，請參見函數(shù)列表。

   // 通過payload函數(shù)，獲取設備上報的消息內(nèi)容，并按照JSON格式轉換。
   var data = payload("json"); 
   // 篩選出上報的溫濕度值。
   var h = data.items.Humidity.value;
   var t = data.items.Temperature.value;
   // PolarDB MySQL表結構為id[自增主鍵] deviceName、temperature、humidity、time，在writePolarDB方法中，可以按column:value的形式，將值寫入對應的列。
   // 設置溫度值大于30時觸發(fā)規(guī)則。
   if (t > 30) { 
       writePolarDB(1000, {"deviceName":deviceName(), "temperature":t, "time":timestamp(), "humidity":h});  
   }

6. 單擊調試，根據(jù)頁面提示，選擇產(chǎn)品和設備，輸入Topic和Payload數(shù)據(jù)，驗證腳本可執(zhí)行。

   調試參數(shù)示例：

   

   運行結果如下，表示腳本執(zhí)行成功。

   action: 
       transmit to polardb[destinationId=1000], data:{"temperature":38,"humidity":25,"time":1700631588609,"deviceName":"devce****"}
   variables: 
       data : {"deviceType":"CustomCategory","iotId":"JCp9***","requestId":"16269*******7","checkFailedData":{},"productKey":"ic*******z","gmtCreate":1626948134445,"deviceName":"devce****","items":{"temperature":{"time":1626948134319,"value":38},"humidity":{"time":1626948134319,"value":25}}}
       t : 38
       h : 25

7. 單擊發(fā)布。

8. 回到云產(chǎn)品流轉頁面的解析器頁簽，單擊解析器DataParser對應的操作列的啟動，啟動解析器。

后續(xù)操作

• 您可在物聯(lián)網(wǎng)平臺控制臺對應實例下監(jiān)控運維 > 日志服務頁面的云端運行日志頁簽，查看設備到云消息及云產(chǎn)品流轉的運行日志。具體操作，請參見云端運行日志。

• 您可登錄PolarDB控制臺，連接數(shù)據(jù)庫查詢存儲的物聯(lián)網(wǎng)平臺數(shù)據(jù)。具體操作，請參見連接數(shù)據(jù)庫集群。

相關文檔

• 設備接入物聯(lián)網(wǎng)平臺上報數(shù)據(jù)的操作指導，請參見設備接入引導。

• 您可在實例詳情頁面，查看消息轉發(fā)TPS可用資源，確保設備消息能正常轉發(fā)到PolarDB MySQL版存儲。具體操作，請參見查看實例信息和運行數(shù)據(jù)。如果可用資源不足，可進行升配。具體內(nèi)容，請參見升配。

• 使用PolarDB MySQL版存儲數(shù)據(jù)時，費用、集群訪問（讀寫分離）、性能和容量、穩(wěn)定性和存儲空間等常見問題，請參見PolarDB MySQL版的常見問題和解答。