Add handlers & logging config to java-events samples

Author: yualexan

sample-apps/java-events/src/main/java/example/HandlerDynamoDB.java

@@ -0,0 +1,33 @@
+package example;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.LambdaLogger;
+import com.amazonaws.services.lambda.runtime.events.DynamodbEvent;
+import com.amazonaws.services.lambda.runtime.events.DynamodbEvent.DynamodbStreamRecord;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+// Handler value: example.HandlerDynamoDB
+public class HandlerDynamoDB implements RequestHandler<DynamodbEvent, String>{
+  private static final Logger logger = LoggerFactory.getLogger(HandlerDynamoDB.class);
+  Gson gson = new GsonBuilder().setPrettyPrinting().create();
+  @Override
+  public String handleRequest(DynamodbEvent event, Context context)
+  {
+    String response = new String("200 OK");
+    for (DynamodbStreamRecord record : event.getRecords()){
+      logger.info(record.getEventID());
+      logger.info(record.getEventName());
+      logger.info(record.getDynamodb().toString());
+    }
+    logger.info("Successfully processed " + event.getRecords().size() + " records.");
+    // log execution details
+    Util.logEnvironment(event, context, gson);
+    return response;
+  }
+}

sample-apps/java-events/src/main/java/example/HandlerKinesis.java

@@ -0,0 +1,30 @@
+package example;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.LambdaLogger;
+import com.amazonaws.services.lambda.runtime.events.KinesisEvent;
+import com.amazonaws.services.lambda.runtime.events.KinesisEvent.KinesisEventRecord;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+// Handler value: example.HandleKinesis
+public class HandlerKinesis implements RequestHandler<KinesisEvent, String>{
+  private static final Logger logger = LoggerFactory.getLogger(HandlerKinesis.class);
+  Gson gson = new GsonBuilder().setPrettyPrinting().create();
+  @Override
+  public String handleRequest(KinesisEvent event, Context context)
+  {
+    String response = new String("200 OK");
+    for(KinesisEventRecord record : event.getRecords()) {
+      logger.info(gson.toJson(record.getKinesis().getData()));
+    }
+    // log execution details
+    Util.logEnvironment(event, context, gson);
+    return response;
+  }
+}

sample-apps/java-events/src/main/java/example/HandlerS3.java

@@ -0,0 +1,35 @@
+package example;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.LambdaLogger;
+import com.amazonaws.services.lambda.runtime.events.S3Event;
+
+import com.amazonaws.services.lambda.runtime.events.models.s3.S3EventNotification.S3EventNotificationRecord;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+// Handler value: example.Handler
+public class HandlerS3 implements RequestHandler<S3Event, String>{
+    private static final Logger logger = LoggerFactory.getLogger(HandlerS3.class);
+    Gson gson = new GsonBuilder().setPrettyPrinting().create();
+    @Override
+    public String handleRequest(S3Event event, Context context)
+    {
+        String response = new String("200 OK");
+        S3EventNotificationRecord record = event.getRecords().get(0);
+        String srcBucket = record.getS3().getBucket().getName();
+        // Object key may have spaces or unicode non-ASCII characters.
+        String srcKey = record.getS3().getObject().getUrlDecodedKey();
+        logger.info("RECORD: " + record);
+        logger.info("SOURCE BUCKET: " + srcBucket);
+        logger.info("SOURCE KEY: " + srcKey);
+        // log execution details
+        Util.logEnvironment(event, context, gson);
+        return response;
+    }
+}

sample-apps/java-events/src/main/resources/log4j2.xml

@@ -0,0 +1,16 @@
+<Configuration status="WARN">
+  <Appenders>
+    <Lambda name="Lambda">
+      <PatternLayout>
+          <pattern>%d{yyyy-MM-dd HH:mm:ss} %X{AWSRequestId} %-5p %c{1} - %m%n</pattern>
+      </PatternLayout>
+    </Lambda>
+  </Appenders>
+  <Loggers>
+    <Root level="INFO">
+      <AppenderRef ref="Lambda"/>
+    </Root>
+    <Logger name="software.amazon.awssdk" level="WARN" />
+    <Logger name="software.amazon.awssdk.request" level="DEBUG" />
+  </Loggers>
+</Configuration>