Cloud Monitor:Ekspor data pemantauan secara real-time

Contoh

• Contoh 1: Ekspor data pemantauan untuk metrik Availability dari namespace acs_networkmonitor dalam pemantauan situs pada interval reguler.

  1. Dapatkan nilai parameter 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. Ekspor data pemantauan.

     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. Ekspor data pemantauan untuk metrik Availability pada interval reguler.

     Sebagai contoh, jika Anda mengatur interval menjadi 3 detik, data pemantauan diekspor setiap 3 detik.

     public class Demo1 {
         private String cursor;
         @Scheduled(cron = "*/3 * * * * ?")
         public void getCpuData() throws Exception {
             System.out.println("Mulai memperoleh data.");
             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("Berhenti memperoleh data.");
         }
     }

• Contoh 2: Ekspor data pemantauan untuk metrik Availability dan Availability_new dari namespace acs_networkmonitor dalam pemantauan situs pada interval reguler.

  1. Dapatkan nilai parameter 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. Ekspor data pemantauan.

     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. Ekspor metrik pemantauan untuk metrik Availability dan Availability_new pada interval reguler.

     Sebagai contoh, jika Anda mengatur interval menjadi 3 detik, data pemantauan diekspor setiap 3 detik.

     public class Demo2 {
         private String availabilityCursor;
         private String availability_newCursor;
         @Scheduled(cron = "*/3 * * * * ?")
         public void getCpuData() throws Exception {
             System.out.println("Mulai memperoleh data.");
             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("Berhenti memperoleh data.");
         }
     }