IoT Platform：資料轉寄到訊息佇列RocketMQ

使用說明

• 目前，新版和舊版雲產品流轉功能均支援將資料流轉到訊息佇列RocketMQ。舊版雲產品流轉使用樣本，請參見資料轉寄到訊息佇列RocketM（舊版）。

建立資料目的

1. 登入物聯網平台控制台。

2. 在執行個體概覽頁簽的全部環境下，找到對應的執行個體，單擊執行個體卡片。

3. 在左側導覽列，選擇訊息轉寄 > 雲產品流轉。

4. 在雲產品流轉頁面，單擊右上方體驗新版，進入新版功能頁面。

   說明

   如果您已執行過此操作，再次進入雲產品流轉頁面，會直接進入新版功能頁面。

5. 單擊資料目的頁簽，然後單擊建立資料目的。

6. 在建立資料目的對話方塊，輸入資料目的名稱，例如DataPurpose，按照以下參數說明，完成配置，然後單擊確定。

   

   參數	說明
   選擇操作	選擇發送資料到訊息佇列（RocketMQ）中。
   地區	選擇RocketMQ所在地區。
   執行個體	選擇RocketMQ執行個體。 您可以單擊建立執行個體，跳轉到訊息佇列控制台，建立RocketMQ執行個體，請參見訊息佇列文檔。
   Topic	選擇用於接收物聯網平台資料的RocketMQ Topic。 您可以單擊建立Topic，跳轉到訊息佇列控制台，建立RocketMQ Topic。
   授權	授權物聯網平台將資料寫入RocketMQ。 如您還未建立相關角色，單擊建立RAM角色，跳轉到RAM控制台，建立角色和授權策略，請參見建立RAM角色。

配置並啟動解析器

1. 建立解析器，例如DataParser。具體操作，請參見步驟一：建立解析器。

2. 在解析器詳情頁面，關聯資料來源。

   1. 在設定精靈的資料來源下，單擊關聯資料來源。

   2. 在彈出的對話方塊中，單擊資料來源下拉式清單，選擇已建立的資料來源DataSource，單擊確定。

3. 在解析器詳情頁面，關聯資料目的。

   1. 單擊設定精靈的資料目的，然後單擊資料目的列表右上方的關聯資料目的。

   2. 在彈出的對話方塊中，單擊資料目的下拉式清單，選擇已建立的資料目的DataPurpose，單擊確定。

   3. 在資料目的列表，查看並儲存資料目的ID，例如為1000。

      後續解析指令碼中，需使用此處的資料目的ID。

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

5. 在指令碼輸入框，輸入解析指令碼。

   函數參數說明，請參見函數列表。

   //通過payload函數，擷取裝置上報的訊息內容，並按照JSON格式轉換。
   var data = payload("json");
   //直接流轉物模型上報資料。
   writeMq(1000, data, "調試");

6. 單擊調試，根據頁面提示，選擇產品和裝置，輸入Topic和Payload資料，驗證指令碼可執行。

   參數樣本如下：

   運行結果如下，表示指令碼執行成功。

   

7. 單擊發布。

8. 回到雲產品流轉頁面的解析器頁簽，單擊解析器DataParser對應的啟動按鈕，啟動解析器。

9. 在RocketMQ控制台，查看是否成功接收到訊息。