Tüm Ürünler
Search

Bu Ürün

    Cloud Monitor:Gerçek zamanlı izleme verilerini dışa aktarma

    Belge Merkezi

    Cloud Monitor:Gerçek zamanlı izleme verilerini dışa aktarma

    Son Güncelleme:Oct 03, 2026

    Bulut izleme ölçümlerinizi Cursor ve BatchExport API işlemleri aracılığıyla gerçek zamanlı olarak dışa aktarın.

    Ön koşullar

    Hybrid Cloud Monitoring etkinleştirilmiş olmalıdır. Hybrid Cloud Monitoring'i Etkinleştirme.

    Arka plan bilgileri

    Hybrid Cloud Monitoring'i etkinleştirmek ücretsizdir. Kullanıma göre faturalandırılırsınız. Gerçek zamanlı veri dışa aktarma.

    Yordam

    1. Her Alibaba Cloud hizmeti için ölçüm listesini almak üzere DescribeMetricMetaList işlemine çağrı yapın.

      Parametre ayrıntıları için bkz. DescribeMetricMetaList.

      Not

      Her hizmet için Namespace, MetricName, Dimensions, Period ve Statistics değerleri Alibaba Cloud hizmeti ölçümleri bölümünde listelenmiştir.

      1. Maven kullanarak Cloud Monitor SDK bağımlılığını ekleyin.

        <dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>cms20190101</artifactId>
  <version><LATEST_SDK_VERSION></version>
</dependency>

      2. Her Alibaba Cloud hizmeti için ölçüm listesini almak üzere DescribeMetricMetaList işlemine çağrı yapın.

        Örnek SDK isteği:

        private static Client getClient() throws Exception {
    Config config = new Config()
    config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
  	config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
    config.endpoint = "metrics.cn-hangzhou.aliyuncs.com";
    return new Client(config);
}
public static void main(String[] args) throws Exception {
    Client client = getClient();
    DescribeMetricMetaListRequest describeMetricMetaListRequest = new DescribeMetricMetaListRequest();
    describeMetricMetaListRequest.setNamespace("acs_ecs_dashboard");
    DescribeMetricMetaListResponse describeMetricMetaListResponse = client.describeMetricMetaList(describeMetricMetaListRequest);
    String json = JSON.toJSONString(describeMetricMetaListResponse.getBody());
    System.out.println(json);
}

    2. Ölçümleri alın.

      1. pom.xml dosyanıza SDK bağımlılığını ekleyin.

        <dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>cms20190101</artifactId>
    <version><LATEST_SDK_VERSION></version>
</dependency>

      2. Veri dışa aktarma kapsamını tanımlamak için Cursor işlemine çağrı yapın. Bu işlem, ilk BatchExport çağrısı için gerekli olan bir cursor döndürür.

        Parametre ayrıntıları için bkz. Cursor.

        Cursor ve BatchExport işlemleri tüm bölgelerde kullanılabilir. Uç noktalar.

        Örnek SDK isteği:

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

        Örnek SDK yanıtı:

        eyJidWNrZXRzIjo0LCJlbmRUaW1lIjo5MjIzMzcyMDM2ODU0Nzc1ODA3LCJleHBvcnRFbmRUaW1lIjo5MjIzMzcyMDM2ODU0Nzc1ODA3LCJleHByZXNzUmFuZ2UiOmZhbHNlLCJoYXNOZXh0Ijp0cnVlLCJsaW1pdCI6NTAwMCwibG9nVGltZU1vZGUiOnRydWUsIm1hdGNoZXJzIjp7ImNoYWluIjpbeyJsYWJlbCI6InVzZXJJZCIsIm9wZXJhdG9yIjoiRVFVQUxTIiwidmFsdWUiOiIxNzM2NTExMTM0Mzg5MTEwIn0seyJsYWJlbCI6InRhc2tJZCIsIm9wZXJhdG9yIjoiRVFVQUxTIiwidmFsdWUiOiIqIn1dfSwibWV0cmljIjoiQXZhaWxhYmlsaXR5X29yaWdpbmFsIiwibWV0cmljVHlwZSI6Ik1FVFJJQyIsIm5hbWVzcGFjZSI6ImFjc19uZXR3b3JrbW9uaXRvciIsIm5leHRQa0FkYXB0ZXIiOnt9LCJvZmZzZXQiOjAsInN0YXJ0VGltZSI6MTYzODQwNTA1MDcxNywic3RlcCI6LTEsInRpbWVvdXQiOjEyMCwid2luZG93Ijo2****

      3. Cursor işlemi tarafından tanımlanan izleme verilerini dışa aktarmak için BatchExport işlemine çağrı yapın.

        Parametre ayrıntıları için bkz. BatchExport.

        Örnek SDK isteği:

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

        Örnek SDK yanıtı:

        {
    "anchor":"168801465****",
    "code":200,
    "cursor":"eyJidWNrZXdWNrZXRCeXRlcyI6IndBPT0iLCJidWNrZXRzIjo0LCJjdXJyZW50QnVja2V0IjotNjQsImN1cnJlbnRUYXJnZXRUaW1lU2xvdCI6MTY4Nzk5NjgwMCwiZW5kVGltZSI6MTY4ODAxNDgwMDAwMCwiZXhwb3J0RW5kVGltZSI6MTY4ODAxODMxNTU0NywiZXhwb3J0U3RhcnRUaW1lIjoxNjg4MDE0NjU1NTQ3LCJleHByZXNzUmFuZ2UiOmZhbHNlLCJoYXNOZXh0Ijp0cnVlLCJpbmRleCI6MCwibGF0ZXN0TG9nVGltZSI6MCwibWF0Y2hlcnMiOnsiY2hhaW4iOlt7ImxhYmVsIjoidXNlcklkIiwib3BlcmF0b3IiOiJFUVVBTFMiLCJ2YWx1ZSI6IjE3MzY1MTExMzQzODkxMTAifV0sImxvY2tlZCI6dHJ1ZX0sIm1ldHJpYyI6IlNwbGl0cndQcm94eU1heFJlc3BvbnNlU2l6ZSIsIm1ldHJpY1R5cGUiOiJNRVRSSUMiLCJuYW1lc3BhY2UiOiJhY3Nfa3ZzdG9yZV9leCIsIm5leHRQa0FkYXB0ZXIiOnt9LCJvY2MiOlstNjU2MDE3MDUyMjc3MzE4NjY0LDE2ODgwMTgyNTk4MTNdLCJvZmZzZXQiOjEsIm9mZnNldERpZ2l0Ijo1NjgyMjY5NDU3MTc0NTM5ODk1LCJzdGFydFRpbWUiOjE2ODgwMTQ2NTU1NDcsInN0ZXAiOi0xLCJ0YWdNYXRjaGVycyI6eyJjaGFpbiI6W10sImxvY2tlZCI6dHJ1ZX0sInRhcmdldFRpbWVTbG90cyI6WzE2ODc5MTA0MDAsMTY4Nzk5NjgwMF0sInV1aWQiOiJjYjQzNjBjNS00NjY4LTQxZDQtYmRjYi0zMGNhY2M2NDBhNmQiLCJ2Y2MiOlsxMDc3NTkwNTEzMzk4NzczMzk3LDE2ODgwMTgyNTMz****",
    "dataResults":[ 
        {
            "associated":{

            },
            "dimensions":[
                {
                    "label":"userId",
                    "value":"173651113438****"
                },
                {
                    "label":"instanceId",
                    "value":"r-bp12meeb25mb7d****"
                },
                {
                    "label":"nodeId",
                    "value":"r-bp12meeb25mb7d****-proxy-3"
                }
            ],
            "measurements":{
                "Maximum":565.916,
                "Average":565.916
            },
            "metric":"SplitrwProxyMaxResponseSize",
            "namespace":"acs_kvstore",
            "period":60,
            "timestamp":1688014560000
        }
    ],
    "hasNext":true,
    "length":1, 
    "message":"success",  
    "requestId":"8D26C6ED-991C-533E-B601-B020EDF7****",
    "success":true
}

    Örnekler

    • Örnek 1: Site izlemenin acs_networkmonitor ad alanındaki Availability ölçümü için izleme verilerini sürekli olarak dışa aktarın.

      1. Bir cursor alın.

        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(String namespace, String metric, int period, long startTime, long endTime, List<Matcher> matchers) throws Exception {
		Client client = new Client(getConfig(config));
 	  CursorRequest cursorRequest = new CursorRequest();
 	  cursorRequest.setNamespace(namespace);
    cursorRequest.setMetric(metric);
    cursorRequest.setPeriod(period);
    cursorRequest.setStartTime(startTime);
    cursorRequest.setEndTime(endTime);
    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. İzleme verilerini dışa aktarın.

        public class GetDataUtil {
    // ...

    private static String BatchExport(String cursor, String namespace, String metric, int length) throws Exception {
    	Client client = new Client(getConfig(config));
    	BatchExportRequest request = new BatchExportRequest();
    	request.setNamespace(namespace);
    	request.setMetric(metric);
    	request.setCursor(cursor);
    	request.setLength(length);
    	BatchExportResponse response = client.batchExport(request);
    	if (response == null || response.getBody() == null) {
      	return null;
    	}else {
      	String json = JSON.toJSONString(response.getBody());
      	return json;
    	}
	}
}

      3. Availability ölçümü için izleme verilerini sürekli olarak dışa aktarın.

        Aşağıdaki örnekte 3 saniyelik bir zamanlayıcı kullanılmaktadır:

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

    • Örnek 2: Site izlemenin acs_networkmonitor ad alanındaki Availability ve Availability_new ölçümleri için izleme verilerini sürekli olarak dışa aktarın.

      1. Bir cursor alın.

        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(String namespace, String metric, int period, long startTime, long endTime, List<Matcher> matchers) throws Exception {
		Client client = new Client(getConfig(config));
 	  CursorRequest cursorRequest = new CursorRequest();
 	  cursorRequest.setNamespace(namespace);
    cursorRequest.setMetric(metric);
    cursorRequest.setPeriod(period);
    cursorRequest.setStartTime(startTime);
    cursorRequest.setEndTime(endTime);
    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. İzleme verilerini dışa aktarın.

        public class GetDataUtil {
    // ...

    private static String BatchExport(String cursor, String namespace, String metric, int length) throws Exception {
    	Client client = new Client(getConfig(config));
    	BatchExportRequest request = new BatchExportRequest();
    	request.setNamespace(namespace);
    	request.setMetric(metric);
    	request.setCursor(cursor);
    	request.setLength(length);
    	BatchExportResponse response = client.batchExport(request);
    	if (response == null || response.getBody() == null) {
      	return null;
    	}else {
      	String json = JSON.toJSONString(response.getBody());
      	return json;
    	}
	}
}

      3. Availability ve Availability_new ölçümleri için izleme verilerini sürekli olarak dışa aktarın.

        Aşağıdaki örnekte 3 saniyelik bir zamanlayıcı kullanılmaktadır:

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