|
16 | 16 |
|
17 | 17 | import com.amazonaws.services.lambda.runtime.Context; |
18 | 18 | import com.amazonaws.services.lambda.runtime.RequestHandler; |
19 | | -import software.amazon.cloudwatchlogs.emf.logger.MetricsLogger; |
20 | | -import software.amazon.cloudwatchlogs.emf.model.DimensionSet; |
21 | | -import software.amazon.cloudwatchlogs.emf.model.StorageResolution; |
22 | | -import software.amazon.cloudwatchlogs.emf.model.Unit; |
23 | 19 | import software.amazon.lambda.powertools.metrics.FlushMetrics; |
24 | | -import software.amazon.lambda.powertools.metrics.MetricsUtils; |
| 20 | +import software.amazon.lambda.powertools.metrics.Metrics; |
| 21 | +import software.amazon.lambda.powertools.metrics.MetricsFactory; |
| 22 | +import software.amazon.lambda.powertools.metrics.model.DimensionSet; |
| 23 | +import software.amazon.lambda.powertools.metrics.model.MetricResolution; |
| 24 | +import software.amazon.lambda.powertools.metrics.model.MetricUnit; |
25 | 25 | import java.time.LocalDateTime; |
26 | 26 | import java.time.ZoneOffset; |
27 | 27 | import java.time.temporal.ChronoUnit; |
28 | 28 | import java.time.Instant; |
29 | 29 |
|
30 | | - |
31 | 30 | public class Function implements RequestHandler<Input, String> { |
32 | 31 |
|
33 | | - MetricsLogger metricsLogger = MetricsUtils.metricsLogger(); |
| 32 | + Metrics metrics = MetricsFactory.getMetricsInstance(); |
34 | 33 |
|
35 | 34 | @FlushMetrics(captureColdStart = true) |
36 | 35 | public String handleRequest(Input input, Context context) { |
37 | 36 |
|
38 | | - Instant currentTimeTruncatedPlusThirty = |
39 | | - LocalDateTime.now().truncatedTo(ChronoUnit.MINUTES).toInstant(ZoneOffset.UTC).plusSeconds(30); |
40 | | - metricsLogger.setTimestamp(currentTimeTruncatedPlusThirty); |
| 37 | + Instant currentTimeTruncatedPlusThirty = LocalDateTime.now().truncatedTo(ChronoUnit.MINUTES) |
| 38 | + .toInstant(ZoneOffset.UTC).plusSeconds(30); |
| 39 | + metrics.setTimestamp(currentTimeTruncatedPlusThirty); |
41 | 40 |
|
42 | 41 | DimensionSet dimensionSet = new DimensionSet(); |
43 | 42 | input.getDimensions().forEach((key, value) -> dimensionSet.addDimension(key, value)); |
44 | | - metricsLogger.putDimensions(dimensionSet); |
| 43 | + metrics.addDimension(dimensionSet); |
45 | 44 |
|
46 | | - input.getMetrics().forEach((key, value) -> metricsLogger.putMetric(key, value, Unit.COUNT, |
47 | | - input.getHighResolution().equalsIgnoreCase("true") ? StorageResolution.HIGH : |
48 | | - StorageResolution.STANDARD)); |
| 45 | + input.getMetrics().forEach((key, value) -> metrics.addMetric(key, value, MetricUnit.COUNT, |
| 46 | + input.getHighResolution().equalsIgnoreCase("true") ? MetricResolution.HIGH |
| 47 | + : MetricResolution.STANDARD)); |
49 | 48 |
|
50 | 49 | return "OK"; |
51 | 50 | } |
|
0 commit comments