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

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

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

GetMetricStatisticsRequest.<init>介绍

暂无

代码示例

代码示例来源:origin: stackoverflow.com

final long twoWeeks = 1000 * 60 * 60 * 24 * 15;
final int twelveHours = 60 * 60 * 12;
return new GetMetricStatisticsRequest()
  .withStartTime(new Date(new Date().getTime() - twoWeeks))
  .withNamespace("AWS/Billing")

代码示例来源: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: stackoverflow.com

private static void findCloudWatchData()  {

LinkedHashMap<Date,Double> map=new HashMap<Date,Double>();
AmazonCloudWatchClient cloudWatch = new AmazonCloudWatchClient(new BasicAWSCredentials(AccessKey,     SecretKey));
cloudWatch.setEndpoint("monitoring.us-east-1.amazonaws.com");
long offsetInMilliseconds = 1000 * 60 * 60 * 24;
Dimension instanceDimension = new Dimension();
instanceDimension.setName("instanceid");
instanceDimension.setValue(instanceid);

GetMetricStatisticsRequest request = new GetMetricStatisticsRequest()
    .withStartTime(new Date(new Date().getTime() - offsetInMilliseconds))
    .withNamespace("AWS/EC2")
    .withPeriod(60 * 60)
    .withMetricName("CPUUtilization")
    .withStatistics("Average")
    .withDimensions(Arrays.asList(instanceDimension))
    .withEndTime(new Date());

GetMetricStatisticsResult getMetricStatisticsResult = cloudWatch.getMetricStatistics(request);
}

//To read the Data
for (Datapoint dp : result.getDatapoints()) {
  map.put(dp.getTimeStamp(), dp.getAverage());   //or getMaximum() or whatever Statistics you are interested in. You can also maintain a list of the statistics you are interested in. Ex: request.setStatistics(list) 
}

代码示例来源: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: petezybrick/awscwxls

initStatisticsByMetric( extractItem.getMetricStatisticNames() );
List<DimensionMetric> dimensionMetrics = new ArrayList<DimensionMetric>();
GetMetricStatisticsRequest getMetricRequest = new GetMetricStatisticsRequest();
getMetricRequest.setNamespace( extractItem.getNamespace() );
getMetricRequest.setPeriod( extractItem.getPeriodMinutes() * 60 );

代码示例来源:origin: prometheus/cloudwatch_exporter

Date startDate = new Date(start - 1000 * rule.delaySeconds);
Date endDate = new Date(start - 1000 * (rule.delaySeconds + rule.rangeSeconds));
GetMetricStatisticsRequest request = new GetMetricStatisticsRequest();
request.setNamespace(rule.awsNamespace);
request.setMetricName(rule.awsMetricName);

代码示例来源: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;
  }
}

相关文章

微信公众号

最新文章

更多