實(shí)時(shí)導(dǎo)出監(jiān)控?cái)?shù)據(jù)示例

• 示例1：連續(xù)導(dǎo)出云監(jiān)控中站點(diǎn)監(jiān)控acs_networkmonitor的監(jiān)控指標(biāo)Availability的監(jiān)控?cái)?shù)據(jù)。

  1. 獲取Cursor。

     public class GetDataUtil {
         private static Config config = null;
     		private static Config getConfig(Config config){
       	config = new Config();
       	config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
       	config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
       	config.setEndpoint("metrics.cn-hangzhou.aliyuncs.com");
       	return config;
     	}
     	private static String getCursor() throws Exception {
     		Client client = new Client(getConfig(config));
      	  CursorRequest cursorRequest = new CursorRequest();
      	  cursorRequest.setNamespace("acs_ecs_dashboard");
         cursorRequest.setMetric("CPUUtilization");
         cursorRequest.setPeriod(60);
         cursorRequest.setStartTime(System.currentTimeMillis() - 60 * 60 * 1000);
         cursorRequest.setEndTime(Long.MAX_VALUE);
       	List<Matcher> matchers = new ArrayList<>();
       	Matcher matcher = new Matcher();
       	matcher.setLabel("userId");
         matcher.setValue("173651113438****");
       	matcher.setOperator("EQUALS");
       	matchers.add(matcher);
         cursorRequest.setMatchers(matchers);
         CursorResponse cursorResponse = client.cursor(cursorRequest);
         if (cursorResponse == null || cursorResponse.getBody() == null || cursorResponse.getBody().getCursor() == null) {
           return null;
         }
         return cursorResponse.getBody().getCursor();
     	}
     
         // ...
     }

  2. 導(dǎo)出監(jiān)控?cái)?shù)據(jù)。

     public class GetDataUtil {
         // ...
     
         private static String BatchExport(String cursor) throws Exception {
         	Client client = new Client(getConfig(config));
         	BatchExportRequest request = new BatchExportRequest();
         	request.setNamespace("acs_ecs_dashboard");
         	request.setMetric("CPUUtilization");
         	request.setCursor(cursor);
         	request.setLength(1000);
         	BatchExportResponse response = client.batchExport(request);
         	if (response == null || response.getBody() == null) {
           	return null;
         	}else {
           	String json = JSON.toJSONString(response.getBody());
           	return json;
         	}
     	}
     }

  3. 連續(xù)導(dǎo)出監(jiān)控指標(biāo)Availability的監(jiān)控?cái)?shù)據(jù)。

     例如：設(shè)置定時(shí)器為3秒，即每3秒導(dǎo)出一次監(jiān)控?cái)?shù)據(jù)。

     public class Demo1 {
         private String cursor;
         @Scheduled(cron = "*/3 * * * * ?")
         public void getCpuData() throws Exception {
             System.out.println("開始獲取數(shù)據(jù)。");
             if(cursor == null){
                 Matcher matcher = new Matcher();
                 matcher.setLabel("userId").setOperator("EQUALS").setValue("173651113438****");
                 List<Matcher> chain  = new ArrayList<>();
                 chain.add(matcher);
                 cursor = GetDataUtil.getCursor("acs_networkmonitor","Availability",60,System.currentTimeMillis() - 60 * 60 * 1000,Long.MAX_VALUE,chain);
             }
             String sth = GetDataUtil.BatchExport(cursor,"acs_networkmonitor","Availability",10);
             JSONObject jsonObject = JSONObject.parseObject(sth);
             if(!StringUtils.isEmpty(jsonObject.getString("cursor"))){
                 cursor = jsonObject.getString("cursor");
             }
             System.out.println("結(jié)束獲取數(shù)據(jù)。");
         }
     }

• 示例2：連續(xù)導(dǎo)出云監(jiān)控中站點(diǎn)監(jiān)控acs_networkmonitor的監(jiān)控指標(biāo)Availability和Availability_new的監(jiān)控?cái)?shù)據(jù)。

  1. 獲取Cursor。

     public class GetDataUtil {
         private static Config config = null;
     		private static Config getConfig(Config config){
       	config = new Config();
       	config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
       	config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
       	config.setEndpoint("metrics.cn-hangzhou.aliyuncs.com");
       	return config;
     	}
     	private static String getCursor() throws Exception {
     		Client client = new Client(getConfig(config));
      	  CursorRequest cursorRequest = new CursorRequest();
      	  cursorRequest.setNamespace("acs_ecs_dashboard");
         cursorRequest.setMetric("CPUUtilization");
         cursorRequest.setPeriod(60);
         cursorRequest.setStartTime(System.currentTimeMillis() - 60 * 60 * 1000);
         cursorRequest.setEndTime(Long.MAX_VALUE);
       	List<Matcher> matchers = new ArrayList<>();
       	Matcher matcher = new Matcher();
       	matcher.setLabel("userId");
         matcher.setValue("173651113438****");
       	matcher.setOperator("EQUALS");
       	matchers.add(matcher);
         cursorRequest.setMatchers(matchers);
         CursorResponse cursorResponse = client.cursor(cursorRequest);
         if (cursorResponse == null || cursorResponse.getBody() == null || cursorResponse.getBody().getCursor() == null) {
           return null;
         }
         return cursorResponse.getBody().getCursor();
     	}
     
         // ...
     }

  2. 導(dǎo)出監(jiān)控?cái)?shù)據(jù)。

     public class GetDataUtil {
         // ...
     
         private static String BatchExport(String cursor) throws Exception {
         	Client client = new Client(getConfig(config));
         	BatchExportRequest request = new BatchExportRequest();
         	request.setNamespace("acs_ecs_dashboard");
         	request.setMetric("CPUUtilization");
         	request.setCursor(cursor);
         	request.setLength(1000);
         	BatchExportResponse response = client.batchExport(request);
         	if (response == null || response.getBody() == null) {
           	return null;
         	}else {
           	String json = JSON.toJSONString(response.getBody());
           	return json;
         	}
     	}
     }

  3. 連續(xù)導(dǎo)出監(jiān)控指標(biāo)Availability和Availability_new的監(jiān)控?cái)?shù)據(jù)。

     例如：設(shè)置定時(shí)器為3秒，即每3秒導(dǎo)出一次監(jiān)控?cái)?shù)據(jù)。

     public class Demo2 {
         private String availabilityCursor;
         private String availability_newCursor;
         @Scheduled(cron = "*/3 * * * * ?")
         public void getCpuData() throws Exception {
             System.out.println("開始獲取數(shù)據(jù)。");
             if(availabilityCursor == null){
                 Matcher matcher = new Matcher();
                 matcher.setLabel("userId").setOperator("EQUALS").setValue("173651113438****");
                 List<Matcher> chain  = new ArrayList<>();
                 chain.add(matcher);
                 availabilityCursor = GetDataUtil.getCursor("acs_networkmonitor","Availability",60,System.currentTimeMillis() - 60 * 60 * 1000,Long.MAX_VALUE,chain);
             }
             if(availability_newCursor == null){
                 Matcher matcher = new Matcher();
     						matcher.setLabel("userId").setOperator("EQUALS").setValue("173651113438****");
                 List<Matcher> chain  = new ArrayList<>();
                 chain.add(matcher);
                 availability_newCursor = GetDataUtil.getCursor("acs_networkmonitor","Availability_new",60,System.currentTimeMillis() - 60 * 60 * 1000,Long.MAX_VALUE,chain);
             }
             String sth1 = GetDataUtil.BatchExport(availabilityCursor,"acs_networkmonitor","Availability",10);
             String sth2 = GetDataUtil.BatchExport(availability_newCursor,"acs_networkmonitor","Availability_new",10);
             JSONObject jsonObject1 = JSONObject.parseObject(sth1);
             if(!StringUtils.isEmpty(jsonObject1.getString("cursor"))){
                 availabilityCursor = jsonObject1.getString("cursor");
             }
             System.out.println("availability");
             System.out.println(sth1);
             JSONObject jsonObject2 = JSONObject.parseObject(sth2);
             if(!StringUtils.isEmpty(jsonObject2.getString("cursor"))){
                 availability_newCursor = jsonObject2.getString("cursor");
             }
             System.out.println("availability_new");
             System.out.println(sth2);
             System.out.println("結(jié)束獲取數(shù)據(jù)。");
         }
     }