Skip to content

Commit 611e334

Browse files
szlisieckiSzymon Lisiecki
andauthored
Aws metrics (#10)
* add cloudwatch metrics * add cloudwatch metrics - add service profile --------- Co-authored-by: Szymon Lisiecki <[email protected]>
1 parent e35f240 commit 611e334

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

src/main/java/com/orange/lo/sample/mqtt2eventhub/ConnectorApplication.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,15 @@
1818
import org.springframework.boot.SpringApplication;
1919
import org.springframework.boot.autoconfigure.SpringBootApplication;
2020
import org.springframework.context.annotation.Bean;
21+
import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider;
2122
import software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient;
2223

2324
import java.lang.invoke.MethodHandles;
2425

2526
@SpringBootApplication
2627
public class ConnectorApplication {
2728

29+
private static final String AWS_SERVICE_PROFILE_NAME = "service-profile";
2830
private static final Logger LOG = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
2931
private final MetricsProperties metricsProperties;
3032

@@ -38,8 +40,13 @@ public static void main(String[] args) {
3840

3941
@Bean
4042
public MeterRegistry meterRegistry() {
41-
CloudWatchMeterRegistry cloudWatchMeterRegistry = new CloudWatchMeterRegistry(cloudWatchConfig(), Clock.SYSTEM, CloudWatchAsyncClient.create());
42-
cloudWatchMeterRegistry.config()
43+
CloudWatchAsyncClient cloudWatchAsyncClient = CloudWatchAsyncClient.builder()
44+
.credentialsProvider(ProfileCredentialsProvider.create(AWS_SERVICE_PROFILE_NAME))
45+
.build();
46+
47+
CloudWatchMeterRegistry cloudWatchMeterRegistry = new CloudWatchMeterRegistry(cloudWatchConfig(), Clock.SYSTEM, cloudWatchAsyncClient);
48+
49+
cloudWatchMeterRegistry.config()
4350
.meterFilter(MeterFilter.deny(id -> !id.getName().startsWith("message")))
4451
.commonTags(metricsProperties.getDimensionName(), metricsProperties.getDimensionValue());
4552
return cloudWatchMeterRegistry;

0 commit comments

Comments
 (0)