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