設備連接物聯網平臺后，數據直接上報至物聯網平臺，平臺上的數據可以通過AMQP通道流轉至您的服務器。本文為您介紹配置AMQP服務端訂閱設備消息的方法。

背景信息

創建AMQP服務端訂閱消費組，用來消費設備產生的業務數據；使用規則引擎功能將指定Topic中的消息流轉到AMQP服務端訂閱消費組；您的云端應用可通過監聽消費組獲取消息。
物聯網平臺提供服務端訂閱和云產品流轉兩種功能，實現企業服務器通過接入AMQP客戶端，接收冷鏈運輸追蹤器上報的數據。本文描述兩種配置方法，您可根據實際場景進行選擇：
  • 訂閱設備上報的自定義數據和物模型數據（屬性上報、事件上報、屬性設置響應和服務調用響應），請參見配置AMQP服務端訂閱消息組。
  • 將設備上報的自定義數據或物模型數據進行處理后，再流轉到AMQP服務端訂閱。本示例提供自定義Topic數據的流轉規則，請參見配置數據流轉規則。

創建消費組

  1. 登錄物聯網平臺控制臺。
  2. 在實例概覽頁面，找到對應的企業版實例，單擊實例進入實例詳情頁面。
  3. 在左側導航欄，選擇消息轉發 > 服務端訂閱，單擊消費組列表頁簽。
  4. 單擊創建消費組。
  5. 在創建消費組對話框中，輸入組名（例如：冷鏈運輸追蹤器上報數據），單擊確認。
    冷鏈運輸追蹤器上報數據

配置AMQP服務端訂閱消息組

  1. 登錄物聯網平臺控制臺。
  2. 在實例概覽頁面，找到對應的企業版實例，單擊實例進入實例詳情頁面。
  3. 在左側導航欄，選擇消息轉發 > 服務端訂閱。
  4. 在服務端訂閱頁面，單擊創建訂閱。
  5. 在創建訂閱對話框中，完成配置，單擊確認。
    參數說明
    產品選擇冷鏈運輸追蹤器。
    訂閱類型選擇為AMQP。
    消費組單擊選擇目標消費組對話框右下角的創建消費組，新建消費組（例如：冷鏈運輸追蹤器上報數據）。消費組相關說明，請參見管理消費組。
    推送消息類型服務端要訂閱的消息類型。本示例選擇設備上報消息。詳細說明，請參見設置訂閱。

配置數據流轉規則

  1. 登錄物聯網平臺控制臺。
  2. 在實例概覽頁面，找到對應的企業版實例，單擊實例進入實例詳情頁面。
  3. 在左側導航欄，選擇消息轉發 > 云產品流轉。
  4. 在云產品流轉頁面，單擊創建規則。
    重要 若當前頁面顯示新版功能，先單擊右上角返回舊版，進入舊版功能頁面，再單擊創建規則。
  5. 填寫參數后，單擊確認。
    本案例規則名稱為車廂數據流轉到業務ECS，數據格式為JSON。其他參數自定義，更多信息，請參見設置數據流轉規則。
  6. 規則創建成功后，單擊對應規則后的查看，頁面將跳轉到數據流轉規則頁。您需編輯處理消息數據的SQL，設置數據轉發目的地。
    流轉規則
    1. 單擊編寫SQL，在彈出對話框中，輸入SELECT的字段，并選擇自定義的Topic，單擊確認。
      如下所示，請您根據實際情況編寫SQL。本示例完整SQL語句如下：
      SELECT  timestamp('yyyy-MM-dd HH:mm:ss') as timestamp,deviceName() as deviceName, Temperature, Humidity,Speed FROM "/YourProductKey/+/user/data/post"

      SQL編寫方法，請參見SQL表達式和函數列表。

      編寫SQL
    2. 單擊轉發數據一欄的添加操作，設置數據轉發目的地為已創建的消費組（冷鏈運輸追蹤器上報數據）。具體操作，請參見數據轉發到表格存儲（Tablestore）。
      轉到消費組
  7. 回到云產品流轉頁，單擊規則對應的啟動按鈕，啟動規則。

后續步驟

AMQP客戶端接入