886      阿里云

Topic 写入统计__发布订阅统计接口_Open API_消息队列 MQ-阿里云

本文档介绍 OnsTrendTopicInputTps 接口，调用该接口可以查询一段时间内指定 Topic 的消息写入报表数据。

1. 使用场景

线上环境统计 Topic 的消息数据可以使用该接口获取信息，根据类型可以选择查询指定时间段内 Topic 的写入量或者 TPS 曲线数据。

如果应用方消息量比较小，间隔不均匀，此时采用 TPS 查询可能会导致数据不明显，建议使用总量查询。

2. 请求参数列表

3. 返回参数列表

Data 数据集定义

StatsDataDo 数据集定义

4. 相关 API

• OnsTrendGroupOutputTps：查询 CID 的消息消费统计

5. 使用示例

调用示例

    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";
            /**
            *根据自己需要访问的区域选择Region，并设置对应的接入点
            */
            try {
                DefaultProfile.addEndpoint(endPointName，regionId，productName，domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId，accessKey，secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
            OnsTrendTopicInputTpsRequest request =new OnsTrendTopicInputTpsRequest();
            request.setOnsRegionId("cn-qingdao-publictest");
            request.setPreventCache(System.currentTimeMillis());
            request.setAcceptFormat(FormatType.JSON);
            request.setTopic("MingduanTestAPI");
            request.setBeginTime(System.currentTimeMillis()-4*3600*1000);
            request.setEndTime(System.currentTimeMillis());
            request.setPeriod(1);
            request.setType(0);
            try {
                OnsTrendTopicInputTpsResponse response =iAcsClient.getAcsResponse(request);
                OnsTrendTopicInputTpsResponse.Data data =response.getData();
                System.out.println(data.getTitle()+"n"+
                data.getRecords());
            } catch (ClientException e) {
                e.printStackTrace();
            }
        }