Rejig parameters example to use the CRT client more heavily

Author: scottgerring

examples/powertools-examples-parameters/locustfile.py

@@ -0,0 +1,9 @@
+import time
+from locust import HttpUser, task, between
+
+class QuickstartUser(HttpUser):
+    wait_time = between(1, 5)
+
+    @task
+    def hello_world(self):
+        self.client.get("/Prod/params/")

examples/powertools-examples-parameters/src/main/java/org/demo/parameters/ParametersFunction.java

@@ -14,6 +14,7 @@
 
 package org.demo.parameters;
 
+import static java.time.temporal.ChronoUnit.MILLIS;
 import static java.time.temporal.ChronoUnit.SECONDS;
 import static software.amazon.lambda.powertools.parameters.transform.Transformer.base64;
 import static software.amazon.lambda.powertools.parameters.transform.Transformer.json;
@@ -57,50 +58,33 @@ public class ParametersFunction implements RequestHandler<APIGatewayProxyRequest
             .withTransformationManager(new TransformationManager())
             .build();
 
-    String simpleValue = ssmProvider.withMaxAge(30, SECONDS).get("/powertools-java/sample/simplekey");
-    String listValue = ssmProvider.withMaxAge(60, SECONDS).get("/powertools-java/sample/keylist");
-    MyObject jsonObj = ssmProvider.withTransformation(json).get("/powertools-java/sample/keyjson", MyObject.class);
-    Map<String, String> allValues = ssmProvider.getMultiple("/powertools-java/sample");
-    String b64value = ssmProvider.withTransformation(base64).get("/powertools-java/sample/keybase64");
-
-    Map<String, String> secretJson =
-            secretsProvider.withTransformation(json).get("/powertools-java/userpwd", Map.class);
-    MyObject secretJsonObj = secretsProvider.withMaxAge(42, SECONDS).withTransformation(json)
-            .get("/powertools-java/secretcode", MyObject.class);
 
     @Override
     public APIGatewayProxyResponseEvent handleRequest(APIGatewayProxyRequestEvent input, Context context) {
 
-        log.info("\n=============== SSM Parameter Store ===============");
-        log.info("simplevalue={}, listvalue={}, b64value={}\n", simpleValue, listValue, b64value);
-        log.info("jsonobj={}\n", jsonObj);
+        String simpleValue = ssmProvider.withMaxAge(1, MILLIS).get("/powertools-java/sample/simplekey");
+        String listValue = ssmProvider.withMaxAge(1, MILLIS).get("/powertools-java/sample/keylist");
+        String jsonObj = ssmProvider.withMaxAge(1, MILLIS).get("/powertools-java/sample/keyjson");
+        Map<String, String> allValues = ssmProvider.withMaxAge(1, MILLIS).getMultiple("/powertools-java/sample");
+
 
         log.info("allvalues (multiple):");
         allValues.forEach((key, value) -> log.info("- {}={}\n", key, value));
 
-        log.info("\n=============== Secrets Manager ===============");
-        log.info("secretjson:");
-        secretJson.forEach((key, value) -> log.info("- {}={}\n", key, value));
-        log.info("secretjsonobj={}\n", secretJsonObj);
-
         Map<String, String> headers = new HashMap<>();
         headers.put("Content-Type", "application/json");
         headers.put("X-Custom-Header", "application/json");
 
         APIGatewayProxyResponseEvent response = new APIGatewayProxyResponseEvent()
                 .withHeaders(headers);
-        try {
-            final String pageContents = this.getPageContents("https://checkip.amazonaws.com");
-            String output = String.format("{ \"message\": \"hello world\", \"location\": \"%s\" }", pageContents);
-
-            return response
-                    .withStatusCode(200)
-                    .withBody(output);
-        } catch (IOException e) {
-            return response
-                    .withBody("{}")
-                    .withStatusCode(500);
-        }
+
+        //final String pageContents = this.getPageContents("https://checkip.amazonaws.com");
+        String output = String.format("{ \"message\": \"hello world\", \"location\": \"%s\" }", "bloop");
+
+        return response
+                .withStatusCode(200)
+                .withBody(output);
+
     }
 
     private String getPageContents(String address) throws IOException {
@@ -110,3 +94,4 @@ private String getPageContents(String address) throws IOException {
         }
     }
 }
+

examples/powertools-examples-parameters/src/main/resources/log4j2.xml

@@ -1,12 +1,12 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<Configuration packages="com.amazonaws.services.lambda.runtime.log4j2">
+<Configuration>
     <Appenders>
         <Console name="JsonAppender" target="SYSTEM_OUT">
-            <LambdaJsonLayout compact="true" eventEol="true"/>
+            <JsonTemplateLayout eventTemplateUri="classpath:LambdaJsonLayout.json" />
         </Console>
     </Appenders>
     <Loggers>
-        <Logger name="JsonLogger" level="INFO" additivity="false">
+        <Logger name="com.example" level="debug" additivity="false">
             <AppenderRef ref="JsonAppender"/>
         </Logger>
         <Root level="info">

examples/powertools-examples-parameters/template.yaml

@@ -19,9 +19,17 @@ Resources:
       Handler: org.demo.parameters.ParametersFunction::handleRequest
       MemorySize: 512
       Tracing: Active
+      Timeout: 60
       Environment:
         Variables:
           LOG_LEVEL: INFO
+          #AWS_CODEGURU_PROFILER_ENABLED: TRUE
+          #AWS_CODEGURU_PROFILER_GROUP_ARN: arn:aws:codeguru-profiler:eu-central-1:262576971904:profilingGroup/PowertoolsIdempProfile
+          AWS_CODEGURU_PROFILER_GROUP_NAME: v3ProfileWithCrtFocus
+          AWS_CODEGURU_PROFILER_TARGET_REGION: eu-central-1
+          AWS_CODEGURU_PROFILER_HEAP_SUMMARY_ENABLED: TRUE
+          JAVA_TOOL_OPTIONS: -javaagent:/opt/codeguru-profiler-java-agent-standalone.jar
+
       Policies:
         - AWSSecretsManagerGetSecretValuePolicy:
             SecretArn: !Ref UserPwd