Distributed Message Service RocketMQ

Querying the Message Write TPS of a Topic Within a Specified Period

2024-07-08 08:47:15

API Introduction

Used to query the message write TPS of a topic within a specified period.

API Restrictions

None.

URl

GET       https://[endpoint]/v2/topic/inputTps

Request Parameters

Request Parameters

Required or Not

Position

Parameter Type

Description

prodInstId

Yes

url

String

Instance   ID

topicName

Yes

url

String

Topic   Name

brokerName

Yes

url

String

Broker   Name

Response Parameter

Response Parameter

Parameter Type

Description

statusCode

String

The   status code of the interface on the system layer. Success: 800; failure: 900.

message

String

Status   Description

returnObj

String

Return   the object. The parameters included in this parameter are described in the   comments in Response Examples.

Description of Return Value returnObj

Response Parameter

Parameter Type

Description

data

Json

TPS   Information

Description of Return Value data

Response Parameter

Parameter Type

Description

prodInstId

String

Instance   ID

topicName

String

Topic   Name

tpsVoList

List<TPSVo>

TPS   List

Description of Return Value TPSVo

Response Parameter

Parameter Type

Description

tps

Double

Tps

crtTime

Date

Date   Timestamp

 

Sample Request

GET       https://[endpoint]/v2/topic/inputTps?prodInstId=70687660456281088&topicName=test&brokerName=brokera

Examples of a Successful Response

{

    "returnObj":{

        "data":{

            "prodInstId":"mq_test",

            "topicName":"test",

            "tpsVoList":[

                {

                    "tps":0,

                    "crtTime":1661937180392

                },

                {

                    "tps":0.3,

                    "crtTime":1661937200405

                },

                {

                    "tps":0.3333333333333333,

                    "crtTime":1661937220359

                }

            ]

        }

    },

    "message":"success",

    "statusCode":800

}

Example of a Failed Response

{

    "returnObj": {},

    "message": "...",

    "statusCode": "900"

}


.MdhGzW4ZKy2