管理消費組 - IoT Platform

消費組是訊息消費端的身份標識。訊息消費端以消費組身份接入物聯網平台，並接收物聯網平台轉寄到消費組的訊息。本文介紹如何在物聯網平台添加、查看和刪除消費組。

功能說明

您可通過以下方法監聽消費組，擷取轉寄的訊息。

配置AMQP服務端訂閱：使用AMQP服務端訂閱功能，訂閱某產品下全部裝置的指定類型訊息，並將訊息流程轉到指定消費組。
服務端訂閱和雲產品流轉的區別，請參見資料流轉方案對比。
設定資料流轉規則：使用雲產品流轉功能，將指定Topic中的訊息流程轉到AMQP服務端訂閱消費組。

將消費組ID配置到AMQP用戶端上，AMQP用戶端以消費組身份接入物聯網平台，接收訊息。具體說明，請參見AMQP用戶端接入說明。

多個AMQP用戶端（最多64個）可以使用同一個消費組ID，組成訊息消費叢集。當裝置訊息到達時，物聯網平台將訊息隨機發往消費組ID中的任一個用戶端。

重要

多個消費組需對應啟動多個AMQP用戶端，即單次啟動的一個AMQP用戶端中不可以配置多個消費組ID。

登入物聯網平台控制台。
在執行個體概覽頁簽的全部環境下，找到對應的執行個體，單擊執行個體卡片。
在左側導覽列，選擇訊息轉寄 > 服務端訂閱，單擊消費組列表頁簽。
單擊建立消費組。
在建立消費組對話方塊中，輸入組名，單擊確認。
消費組名稱支援中文、英文字母、日文、數字和底線（_），長度範圍為4~30個字元。一個中文或日文佔2個字元。

您可以查看消費組內的訊息消費速率、訊息堆積量，也可以設定CloudMonitor警示規則來監控消費組。

在消費組列表中，找到要查看的消費組，並單擊對應的查看。
在消費組狀態頁簽，查看訂閱訊息的即時訊息消費速率、堆積訊息消費速率、訊息堆積量、最近消費時間和線上用戶端列表。
當訊息堆積量大於等於（≥）1時，訊息堆積量右側會顯示清空按鈕，您可清除堆積訊息。
說明
訊息組建立後：
- 若未上線過，此時消費組處於離線狀態，向消費組發送訊息時，不會有訊息堆積。
- 若已上線，然後離線，此時消費組處於離線狀態，向消費組發送訊息時，會有訊息堆積。
在消費組狀態頁簽，單擊警示配置，然後在建立警示規則頁面，配置CloudMonitor閾值警示規則，監控消費組訊息堆積數、消費組訊息消費速率，並接收警示訊息。
您需選擇產品為物聯網平台-服務端訂閱，其他參數根據您的需求設定。具體操作，請參見建立閾值警示規則。
在消費組詳情頁面，單擊消費日誌頁簽，可查看具體的消費記錄。

您建立的消費組可以刪除，物聯網平台的預設消費組不可刪除。刪除消費組後，該組內的所有消費端會停止接收訊息。

警告

刪除消費組成功後，如果服務端訂閱中使用了該消費組，會導致服務端訂閱服務不可用、使用者業務中斷。請謹慎操作。

解除訂閱。如果消費組已關聯訂閱關係，則需先解除訂閱；如果消費組無訂閱關係，請忽略此步驟。
1. 在消費組列表中，單擊消費組對應的查看。
2. 在消費組詳情頁面的訂閱產品頁簽下，單擊產品名對應的解除訂閱，再單擊確認。
  說明
  如果該產品的服務端訂閱只有一個消費組，則不能在消費組詳情頁面解除訂閱。您可返回服務端訂閱頁面的訂閱列表頁簽，編輯或刪除訂閱。
在服務端訂閱頁面的消費組列表頁簽下，單擊消費組對應的刪除，然後單擊確認。

API	描述
CreateConsumerGroup	建立一個消費組，用於建立AMQP服務端訂閱。
UpdateConsumerGroup	修改消費組名稱。
QueryConsumerGroupByGroupId	根據消費組ID查詢消費組詳情。
QueryConsumerGroupList	查詢使用者所有消費組列表，或按消費組名稱進行模糊查詢。
QueryConsumerGroupStatus	使用AMQP服務端訂閱時，查詢某個消費組的狀態，包括線上用戶端資訊、訊息消費速率、訊息堆積數、最近訊息消費時間。
ResetConsumerGroupPosition	使用AMQP服務端訂閱時，清空某個消費組的堆積訊息。
DeleteConsumerGroup	刪除消費組。