Collect statistics on message consumption by CID

OnsTrendGroupOutputTps interface queries statistical information of a consumed message obtained by the specified Consumer ID within a period of time.

Usage

When generating consumption data report for online environment, you can use this interface to query the amount or TPS statistics of the consumed messages.

Query scenario:

• Query the curves of the total consumption
• Query the curves of the consumption TPS

If the application party has a small number of messages which are not evenly distributed, then TPS query may lead to scarce result. Instead, Total query is recommended.

Request parameters

Response parameters

Data set definition

StatsDataDo data set definition

Related APIs

• OnsTrendTopicInputTps: queries the statistics of message input

Example

        public static void main(String []args) {
            String regionId = "cn-hangzhou";
            String accessKey = "XXXXXXXXXXXXXXXXX";
            String secretKey = "XXXXXXXXXXXXXXXXX";
            String endPointName ="cn-hangzhou";
            String productName ="Ons";
            String domain ="ons.cn-hangzhou.aliyuncs.com";
            /**
            *Select Region based on the region you will access, and set the corresponding access point.
            */
            try {
                DefaultProfile.addEndpoint(endPointName，regionId，productName，domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId，accessKey，secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
            OnsTrendGroupOutputTpsRequest request =new OnsTrendGroupOutputTpsRequest();
            request.setOnsRegionId("cn-qingdao-publictest");
            request.setPreventCache(System.currentTimeMillis());
            request.setAcceptFormat(FormatType.JSON);
            request.setTopic("MingduanTestAPI");
            request.setConsumerId("CID_Mingduan");
            request.setBeginTime(System.currentTimeMillis()-4*3600*1000);
            request.setEndTime(System.currentTimeMillis());
            request.setPeriod(1);
            request.setType(0);
            try {
                OnsTrendGroupOutputTpsResponse response =iAcsClient.getAcsResponse(request);
                OnsTrendGroupOutputTpsResponse.Data data =response.getData();
                System.out.println(data.getTitle()+"\n"+
                data.getRecords());
            } catch (ClientException e) {
                e.printStackTrace();
            }