當需要對裝置資料進行複雜或精細化處理,且單個產品下所有裝置或指定裝置的訊息量小於1,000 QPS時,可以使用雲產品流轉功能將物聯網平台資料轉寄到Simple Message Queue (formerly MNS) (SMQ)中,服務端再從SMQ主題中訂閱訊息,實現裝置端與服務端之間高效能的訊息閉環傳輸。本文介紹將資料流轉到資料目的地的完整流程。
工作原理
雲產品流轉可將同一產品所有裝置或指定裝置的指定Topic訊息,即時轉寄到SMQ隊列已訂閱的主題中,您的應用伺服器調用SMQ的介面訂閱訊息。
在上圖中:
使用優勢
Simple Message Queue (formerly MNS)可以保證訊息的可靠性,避免了服務端不可用時導致訊息丟失。同時,Message Service在處理大量訊息並發時,有削峰填穀的作用,保證服務端不會因為突然的並發壓力導致服務不可用。物聯網平台與SMQ的結合,可以實現裝置端與服務端之間高效能的訊息閉環傳輸。
使用限制
物聯網平台執行個體及所在地區支援將資料轉寄到Message Service(MNS)。支援的地區詳細資料,請參見各地區功能說明。
目前,新版和舊版雲產品流轉功能均支援將資料流轉到Message Service(MNS)。新版雲產品流轉使用樣本,請參見資料轉寄到Message Service(新版)。
雲網關產品和裝置,及MQTT型執行個體下產品和裝置,不支援使用雲產品流轉(舊版)功能。如果流轉對應產品和裝置的資料,需要使用雲產品流轉(新版)功能。具體內容,請參見雲產品流轉(新版)。
物聯網平台執行個體下裝置訊息轉寄的更多使用限制,請參見使用限制。
前提條件
已建立資料轉寄規則和編寫處理資料的SQL,請參見設定資料流轉規則。
已建立SMQ主題,並在該主題下建立推送類型為HTTP或隊列的訂閱。SMQ使用方法,請參見輕量訊息佇列(原 MNS) SMQ(Simple Message Queue (formerly MNS))文檔。
重要企業版執行個體中,SMQ主題所在地區必須與該企業版執行個體所在地區一致。
已在您的商務服務器中使用SMQ雲端SDK監聽已訂閱SMQ主題的MNS隊列,才能實現SMQ雲端應用接收物聯網平台裝置訊息。
SMQ雲端SDK調用方法,請參見SDK下載和使用中對應SDK的主題使用手冊。
配置資料轉寄目的
登入物聯網平台控制台。
在執行個體概覽頁簽的全部環境下,找到對應的執行個體,單擊執行個體卡片。
在左側導覽列,選擇 。
單擊規則對應的查看,進入資料流轉規則頁面。
重要若當前頁面為雲產品流轉新版頁面,需先單擊右上方返回舊版,再單擊目標規則對應的查看。
單擊轉寄資料一欄對應的添加操作。
在添加操作對話方塊中,選擇操作為發送資料到Message Service(MNS)中。按照介面提示,設定其他資訊,單擊確認。
參數
描述
選擇操作
選擇發送資料到Message Service(MNS)中。
地區
選擇Message Service所在地區。
主題
選擇接收資料的SMQ主題。
SMQ會將接收到的訊息發送給該主題下的HTTP和隊列類型的訂閱。目前,物聯網平台推送至SMQ主題的訊息,僅可以通過HTTP或隊列兩種方式訂閱。
您可以單擊建立主題,跳轉到Simple Message Queue (formerly MNS)控制台,建立SMQ主題以及訂閱。請參見輕量訊息佇列(原 MNS) SMQ(Simple Message Queue (formerly MNS))文檔。
角色
授權物聯網平台將資料寫入Simple Message Queue (formerly MNS)。
如您還未建立相關角色,單擊建立RAM角色,跳轉到RAM控制台,建立角色和授權策略,請參見建立RAM角色。
回到雲產品流轉頁,單擊規則對應的啟動按鈕啟動規則。
後續操作
您可在物聯網平台控制台對應執行個體下雲端作業記錄。
頁面的雲端作業記錄頁簽,查看裝置到雲訊息及雲產品流轉的作業記錄。具體操作,請參見您可登入輕量訊息佇列(原 MNS)控制台,查看MNS主題推送到隊列的訊息。具體操作,請參見接收訊息。
相關文檔
裝置接入物聯網平台上報資料的操作指導,請參見裝置接入引導。
您可在執行個體詳情頁面,查看訊息轉寄TPS可用資源,確保裝置訊息能正常轉寄到Simple Message Queue (formerly MNS)進行消費。具體操作,請參見查看執行個體資訊和運行資料。如果可用資源不足,可進行升配。具體內容,請參見升配。
查看Simple Message Queue (formerly MNS)主題監控項,瞭解接收訊息的數量。具體操作,請參見查看主題監控項。
您可以使用日誌管理功能將訊息主題的訊息作業日誌推送到Log ServiceLog Service。當訊息的消費確認出現異常時,您可以通過MessageId查詢訊息軌跡等資訊,從而進行異常診斷。具體內容,請參見推送日誌到Log Service和查看日誌Log Service。