使用AMQP服務端訂閱時,調用該接口查詢某個消費組的狀態,包括在線客戶端信息、消息消費速率、消息堆積數、最近消息消費時間。
QPS限制
單個阿里云賬號調用該接口的每秒請求數(QPS)最大限制為5。
調試
您可以在OpenAPI Explorer中直接運行該接口,免去您計算簽名的困擾。運行成功后,OpenAPI Explorer可以自動生成SDK代碼示例。
請求參數
名稱 | 類型 | 是否必選 | 示例值 | 描述 |
---|---|---|---|---|
Action | String | 是 | QueryConsumerGroupStatus | 系統規定參數。取值:QueryConsumerGroupStatus。 |
GroupId | String | 是 | nJRaJPn5U1JITGf****** | 消費組ID。調用CreateConsumerGroup創建消費組成功后,會返回消費組ID。您可以調用QueryConsumerGroupList按消費組名稱查詢消費組ID,也可以在物聯網平臺控制臺對應實例下,選擇消息轉發>服務端訂閱>消費組列表,查看消費組ID。 |
IotInstanceId | String | 否 | iot-cn-0pp1n8t**** | 實例ID。您可在物聯網平臺控制臺的實例概覽頁面,查看當前實例的ID。 重要
實例的更多信息,請參見實例概述。 |
調用API時,除了本文介紹的該API的特有請求參數,還需傳入公共請求參數。公共請求參數說明,請參見公共參數文檔。
返回數據
名稱 | 類型 | 示例值 | 描述 |
---|---|---|---|
AccumulatedConsumeCountPerMinute | Integer | 10 | 消費組堆積消息消費速率,單位:條/分鐘。 |
AccumulationCount | Integer | 13 | 消費組消息堆積數。 |
ClientConnectionStatusList | Array of ConsumerGroupClientConnectionInfo | 消費組的在線客戶端信息,請參見ConsumerGroupClientConnectionInfo。 |
|
ConsumerGroupClientConnectionInfo | |||
AccumulatedConsumeCountPerMinute | Integer | 10 | 消費組的單個客戶端堆積消息消費速率,單位:條/分鐘。 |
ClientId | String | 868575026****** | 在線客戶端ID。 |
ClientIpPort | String | 192.168.1.2:36918 | 在線客戶端IP和端口。 |
OnlineTime | Long | 1591240546649 | 在線客戶端的最后上線時間。取值為1970年01月01日00時00分00秒000毫秒以來的毫秒數。 |
RealTimeConsumeCountPerMinute | Integer | 5 | 消費組的單個客戶端實時消息消費速率,單位:條/分鐘。 |
Code | String | iot.system.SystemException | 調用失敗時,返回的錯誤碼。更多信息,請參見錯誤碼。 |
ConsumerSpeed | Integer | 14 | 消費組消息消費速率,單位:條/分鐘。 |
ErrorMessage | String | 系統異常 | 調用失敗時,返回的出錯信息。 |
LastConsumerTime | String | 2020-05-29T03:37:56.000Z | 最近消息消費時間。為UTC時間,以毫秒計,格式為“yyyy-MM-dd'T'HH:mm:ss.SSSZ”。 |
RealTimeConsumeCountPerMinute | Integer | 14 | 消費組實時消息消費速率,單位:條/分鐘。 |
RequestId | String | E55E50B7-40EE-4B6B-8BBE-D3ED55CCF565 | 阿里云為該請求生成的唯一標識符。 |
Success | Boolean | true | 表示是否調用成功。
|
示例
請求示例
https://iot.cn-shanghai.aliyuncs.com/?Action=QueryConsumerGroupStatus
&GroupId=nJRaJPn5U1JITGf******
&<公共請求參數>
正常返回示例
XML
格式
<QueryConsumerGroupStatusResponse>
<ClientConnectionStatusList>
<ConsumerGroupClientConnectionInfo>
<ClientId>12345-1</ClientId>
<AccumulatedConsumeCountPerMinute>8</AccumulatedConsumeCountPerMinute>
<OnlineTime>1627624830193</OnlineTime>
<ClientIpPort>192.168.1.2:55545</ClientIpPort>
<RealTimeConsumeCountPerMinute>16</RealTimeConsumeCountPerMinute>
</ConsumerGroupClientConnectionInfo>
<ConsumerGroupClientConnectionInfo>
<ClientId>12345-0</ClientId>
<AccumulatedConsumeCountPerMinute>10</AccumulatedConsumeCountPerMinute>
<OnlineTime>1627624829763</OnlineTime>
<ClientIpPort>192.168.1.2:55526</ClientIpPort>
<RealTimeConsumeCountPerMinute>14</RealTimeConsumeCountPerMinute>
</ConsumerGroupClientConnectionInfo>
</ClientConnectionStatusList>
<RequestId>4EC250E4-70CE-546E-9D4A-31D06E04EAD8</RequestId>
<AccumulatedConsumeCountPerMinute>10</AccumulatedConsumeCountPerMinute>
<Success>true</Success>
<RealTimeConsumeCountPerMinute>14</RealTimeConsumeCountPerMinute>
<AccumulationCount>26</AccumulationCount>
<ConsumerSpeed>14</ConsumerSpeed>
</QueryConsumerGroupStatusResponse>
JSON
格式
{
"ClientConnectionStatusList": {
"ConsumerGroupClientConnectionInfo": [
{
"ClientId": "12345-1",
"AccumulatedConsumeCountPerMinute": 8,
"OnlineTime": 1627624830193,
"ClientIpPort": "192.168.1.2:55545",
"RealTimeConsumeCountPerMinute": 16
},
{
"ClientId": "12345-0",
"AccumulatedConsumeCountPerMinute": 10,
"OnlineTime": 1627624829763,
"ClientIpPort": "192.168.1.2:55526",
"RealTimeConsumeCountPerMinute": 14
}
]
},
"RequestId": "4EC250E4-70CE-546E-9D4A-31D06E04EAD8",
"AccumulatedConsumeCountPerMinute": 10,
"Success": true,
"RealTimeConsumeCountPerMinute": 14,
"AccumulationCount": 26,
"ConsumerSpeed": 14
}