您可以使用規則引擎，將物聯網平臺數據轉發到消息隊列（Kafka）中存儲，從而實現消息從設備、物聯網平臺、Kafka到應用服務器之間的全鏈路高可靠傳輸能力。本文介紹將數據流轉到數據目的地的完整流程。

前提條件

  • 已創建消息隊列（Kafka）實例和用于接收數據的Topic。Kafka使用方法，請參見Kafka快速入門。
    重要 Kafka實例所在地域必須與物聯網平臺服務的當前實例所在地域一致。
  • 當前阿里云賬號已添加白名單權限，支持將數據轉發到消息隊列Kafka。您可提交工單申請開通白名單權限。
  • 已創建數據轉發規則和編寫處理數據的SQL，請參見設置數據流轉規則。

背景信息

轉發的數據目的配置完成后，會自動完成以下配置，實現設備數據通過物聯網平臺的規則引擎轉發到消息隊列（Kafka）。

  • 物聯網平臺占用Kafka實例所在虛擬交換機的2個IP地址。
  • 在Kafka實例所在的VPC網絡下創建托管安全組，安全組名稱默認以sg-nsm-開頭。

操作步驟

  1. 登錄物聯網平臺控制臺。
  2. 在實例概覽頁面，選擇目標環境，找到對應的實例，單擊實例ID或備注名稱。
    重要 目前僅開通企業版實例服務的地域下，執行此步驟。其他地域，請跳過此步驟。地域及實例的支持說明，請參見實例概述。
    實例概覽
  3. 在左側導航欄，選擇消息轉發 > 云產品流轉。
  4. 單擊規則對應的查看，進入數據流轉規則頁面。
    重要 若當前頁面為云產品流轉新版頁面，需先單擊右上角返回舊版，再單擊目標規則對應的查看。
  5. 單擊轉發數據一欄對應的添加操作。
  6. 在添加操作對話框中，按照界面提示，設置參數信息，單擊確認。
    參數描述
    選擇操作選擇發送數據到消息隊列（Kafka）中。
    角色授權物聯網平臺將數據寫入Kafka。

    如您還未創建相關角色，單擊創建RAM角色，跳轉到RAM控制臺，創建角色和授權策略，請參見創建RAM角色。

    地域固定為您物聯網平臺實例所在地域。
    實例選擇Kafka實例。

    您可以單擊創建實例，跳轉到消息隊列控制臺，創建Kafka實例。具體操作，請參見創建實例。

    Topic選擇用于接收物聯網平臺數據的Kafka Topic。

    您可以單擊創建Topic，跳轉到消息隊列控制臺，創建Kafka Topic。具體操作，請參見創建Topic。

  7. 回到云產品流轉頁，單擊規則對應的啟動按鈕啟動規則。
  8. 向規則SQL中定義的Topic發布一條消息。
    您可使用設備模擬器進行功能調試。具體操作，請參見設備模擬器。
  9. 在消息隊列Kafka版控制臺對應實例的Topic詳情頁面，查詢流轉的消息。
    消息