本文整理了Java中com.amazonaws.services.cloudwatch.model.GetMetricStatisticsRequest.<init>()
方法的一些代码示例,展示了GetMetricStatisticsRequest.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GetMetricStatisticsRequest.<init>()
方法的具体详情如下:
包路径:com.amazonaws.services.cloudwatch.model.GetMetricStatisticsRequest
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!