com.amazonaws.services.cloudwatch.model.GetMetricStatisticsRequest.withNamespace()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(126)

本文整理了Java中com.amazonaws.services.cloudwatch.model.GetMetricStatisticsRequest.withNamespace()方法的一些代码示例,展示了GetMetricStatisticsRequest.withNamespace()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GetMetricStatisticsRequest.withNamespace()方法的具体详情如下:
包路径:com.amazonaws.services.cloudwatch.model.GetMetricStatisticsRequest
类名称:GetMetricStatisticsRequest
方法名:withNamespace

GetMetricStatisticsRequest.withNamespace介绍

[英]The namespace of the metric, with or without spaces.
[中]度量的命名空间,带或不带空格。

代码示例

代码示例来源:origin: tmobile/pacbot

private static GetMetricStatisticsRequest request(
    final String funcationValue, int hours) {
  final long twentyFourHrs = 1000 * 60 * 60l * hours;
  final int oneHour = 60 * 60 * hours;
  return new GetMetricStatisticsRequest()
      .withStartTime(new Date(new Date().getTime() - twentyFourHrs))
      .withNamespace(PacmanRuleConstants.AWS_LAMBDA)
      .withPeriod(oneHour)
      .withDimensions(
          new Dimension().withName("FunctionName").withValue(
              funcationValue))
      .withMetricName(PacmanRuleConstants.INVOCATIONS)
      .withStatistics("Sum").withEndTime(new Date());
}

代码示例来源:origin: tmobile/pacbot

private static GetMetricStatisticsRequest request(
    final String funcationValue) {
  final int fiveMin = 60 * 60 * 24;
  return new GetMetricStatisticsRequest()
      .withStartTime(new Date(new Date().getTime() - TWENTYFOURHOURS))
      .withNamespace(PacmanRuleConstants.AWS_LAMBDA)
      .withPeriod(fiveMin)
      .withDimensions(
          new Dimension().withName(
              PacmanRuleConstants.FUNCTION_NAME).withValue(
              funcationValue))
      .withMetricName(PacmanRuleConstants.THROTTLES)
      .withStatistics(PacmanRuleConstants.SUM)
      .withEndTime(new Date());
}

代码示例来源:origin: awslabs/amazon-kinesis-scaling-utils

public StreamMetricManager(String streamName, List<KinesisOperationType> types, AmazonCloudWatch cloudWatchClient,
    AmazonKinesisClient kinesisClient) {
  this.streamName = streamName;
  this.trackedOperations.addAll(types);
  this.cloudWatchClient = cloudWatchClient;
  this.kinesisClient = kinesisClient;
  for (KinesisOperationType op : this.trackedOperations) {
    // create CloudWatch request templates for the information we have
    // at this point
    for (String metricName : op.getMetricsToFetch()) {
      GetMetricStatisticsRequest cwRequest = new GetMetricStatisticsRequest();
      cwRequest.withNamespace(CW_NAMESPACE)
          .withDimensions(new Dimension().withName("StreamName").withValue(this.streamName))
          .withPeriod(StreamMonitor.CLOUDWATCH_PERIOD).withStatistics(Statistic.Sum)
          .withMetricName(metricName);
      if (!this.cloudwatchRequestTemplates.containsKey(op)) {
        this.cloudwatchRequestTemplates.put(op, new ArrayList<GetMetricStatisticsRequest>() {
          {
            add(cwRequest);
          }
        });
      } else {
        this.cloudwatchRequestTemplates.get(op).add(cwRequest);
      }
    }
  }
}

代码示例来源:origin: org.apache.beam/beam-sdks-java-io-kinesis

GetMetricStatisticsRequest createMetricStatisticsRequest(
  String streamName, Instant countSince, Instant countTo, Minutes period) {
 return new GetMetricStatisticsRequest()
   .withNamespace(KINESIS_NAMESPACE)
   .withMetricName(INCOMING_RECORDS_METRIC)
   .withPeriod(period.getMinutes() * PERIOD_GRANULARITY_IN_SECONDS)
   .withStartTime(countSince.toDate())
   .withEndTime(countTo.toDate())
   .withStatistics(Collections.singletonList(SUM_STATISTIC))
   .withDimensions(
     Collections.singletonList(
       new Dimension().withName(STREAM_NAME_DIMENSION).withValue(streamName)));
}

代码示例来源:origin: classmethod/gradle-aws-plugin

public GetMetricStatisticsResult getMetricStatistics(String metricName, String namespace, String statistics,
    String extendedStatistics, String unit) throws AmazonServiceException {
  AwsCloudWatchPluginExtension ext = getProject().getExtensions().getByType(AwsCloudWatchPluginExtension.class);
  AmazonCloudWatch cw = ext.getClient();
  GetMetricStatisticsRequest request = new GetMetricStatisticsRequest()
    .withMetricName(metricName)
    .withNamespace(namespace)
    .withStatistics(statistics)
    .withExtendedStatistics(extendedStatistics)
    .withUnit(unit)
    .withEndTime(getEndTime())
    .withStartTime(getStartTime())
    .withPeriod(getPeriod());
  
  if (getDimensions() != null) {
    request.withDimensions(getDimensions().entrySet().stream()
      .map(it -> new Dimension()
        .withName(it.getKey().toString())
        .withValue(it.getValue()))
      .collect(Collectors.toList()));
  }
  
  GetMetricStatisticsResult response = cw.getMetricStatistics(request);
  for (Datapoint metric : response.getDatapoints()) {
    getLogger().debug("Retrieved metric %s", metric.getAverage());
  }
  return response;
}

代码示例来源:origin: yegor256/s3auth

@Override
  @Cacheable(lifetime = Tv.THIRTY, unit = TimeUnit.MINUTES)
  public long bytesTransferred() {
    final Date now = new Date();
    final List<Datapoint> datapoints =
      DefaultHost.this.cloudwatch.get().getMetricStatistics(
        new GetMetricStatisticsRequest()
          .withMetricName("BytesTransferred")
          .withNamespace("S3Auth")
          .withStatistics("Sum")
          .withDimensions(
            new Dimension()
              .withName("Bucket")
              .withValue(this.bucket)
          )
          .withUnit(StandardUnit.Bytes)
          .withPeriod((int) TimeUnit.DAYS.toSeconds(Tv.SEVEN))
          .withStartTime(DateUtils.addWeeks(now, -1))
          .withEndTime(now)
      ).getDatapoints();
    long sum = 0L;
    for (final Datapoint datapoint : datapoints) {
      sum += datapoint.getSum();
    }
    return sum;
  }
}

相关文章

微信公众号

最新文章

更多