477      windows

CID 投遞統計__發布訂閱統計接口_Open API_消息隊列 MQ-阿裏雲

本文檔介紹 OnsTrendGroupOutputTps 接口，調用該接口可以查詢指定 Consumer ID 在一段時間內獲消費消息的統計信息。

1.使用場景

線上環境生成消費數據報表時，可以根據該接口查詢消費消息的數量或者 TPS 統計。

查詢場景:

• 查詢消費總量曲線的統計
• 查詢消費 TPS 曲線的統計

如果應用方消息量比較小，間隔不均勻，此時采用 TPS 查詢可能會導致數據不明顯，建議使用總量查詢。

2. 請求參數列表

3. 返回參數列表

Data 數據集定義

StatsDataDo 數據集定義

4. 相關 API

• OnsTrendTopicInputTps：查詢消息寫入的統計信息

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);
            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();
            }