BAEL-4967-Enterprise AWS Lambda Features

2021-05-23 23:48:43 +01:00
parent b684a59392
commit d532c50497
19 changed files with 592 additions and 0 deletions
@@ -0,0 +1,43 @@
+package com.baeldung.lambda.todo;
+
+import java.io.*;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.RequestStreamHandler;
+import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyRequestEvent;
+import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyResponseEvent;
+import com.baeldung.lambda.todo.config.ExecutionContext;
+import com.baeldung.lambda.todo.service.PostService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Handler for requests to Lambda function.
+ */
+public class App implements RequestStreamHandler {
+    private static final Logger LOGGER = LoggerFactory.getLogger(App.class);
+
+    private String environmentName = System.getenv("ENV_NAME");
+    private ExecutionContext executionContext = new ExecutionContext();
+
+    @Override
+    public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException {
+        context.getLogger().log("App starting\n");
+        context.getLogger().log("Environment: "
+          + environmentName + "\n");
+
+        try {
+            PostService postService = executionContext.getPostService();
+            executionContext.getToDoReaderService()
+              .getOldestToDo()
+              .ifPresent(postService::makePost);
+        } catch (Exception e) {
+            LOGGER.error("Failed: {}", e.getMessage(), e);
+        }
+    }
+}
@@ -0,0 +1,8 @@
+package com.baeldung.lambda.todo.api;
+
+import feign.RequestLine;
+
+public interface PostApi {
+    @RequestLine("POST /posts")
+    void makePost(PostItem item);
+}
@@ -0,0 +1,40 @@
+package com.baeldung.lambda.todo.api;
+
+public class PostItem {
+    private String title;
+    private String body;
+    private int userId;
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getBody() {
+        return body;
+    }
+
+    public void setBody(String body) {
+        this.body = body;
+    }
+
+    public int getUserId() {
+        return userId;
+    }
+
+    public void setUserId(int userId) {
+        this.userId = userId;
+    }
+
+    @Override
+    public String toString() {
+        return "PostItem{"
+          + "title='" + title + '\''
+          + ", body='" + body + '\''
+          + ", userId=" + userId +
+          '}';
+    }
+}
@@ -0,0 +1,10 @@
+package com.baeldung.lambda.todo.api;
+
+import feign.RequestLine;
+
+import java.util.List;
+
+public interface ToDoApi {
+    @RequestLine("GET /todos")
+    List<ToDoItem> getAllTodos();
+}
@@ -0,0 +1,50 @@
+package com.baeldung.lambda.todo.api;
+
+public class ToDoItem {
+    private int userId;
+    private int id;
+    private String title;
+    private boolean completed;
+
+    public int getUserId() {
+        return userId;
+    }
+
+    public void setUserId(int userId) {
+        this.userId = userId;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public boolean isCompleted() {
+        return completed;
+    }
+
+    public void setCompleted(boolean completed) {
+        this.completed = completed;
+    }
+
+    @Override
+    public String toString() {
+        return "ToDoItem{"
+          + "userId=" + userId
+          + ", id=" + id
+          + ", title='" + title + '\''
+          + ", completed=" + completed +
+          '}';
+    }
+}
@@ -0,0 +1,50 @@
+package com.baeldung.lambda.todo.config;
+
+public class Config {
+    private String toDoEndpoint;
+    private String postEndpoint;
+    private String environmentName;
+
+    private Credentials toDoCredentials;
+    private Credentials postCredentials;
+
+    public String getToDoEndpoint() {
+        return toDoEndpoint;
+    }
+
+    public void setToDoEndpoint(String toDoEndpoint) {
+        this.toDoEndpoint = toDoEndpoint;
+    }
+
+    public String getPostEndpoint() {
+        return postEndpoint;
+    }
+
+    public void setPostEndpoint(String postEndpoint) {
+        this.postEndpoint = postEndpoint;
+    }
+
+    public String getEnvironmentName() {
+        return environmentName;
+    }
+
+    public void setEnvironmentName(String environmentName) {
+        this.environmentName = environmentName;
+    }
+
+    public Credentials getToDoCredentials() {
+        return toDoCredentials;
+    }
+
+    public void setToDoCredentials(Credentials toDoCredentials) {
+        this.toDoCredentials = toDoCredentials;
+    }
+
+    public Credentials getPostCredentials() {
+        return postCredentials;
+    }
+
+    public void setPostCredentials(Credentials postCredentials) {
+        this.postCredentials = postCredentials;
+    }
+}
@@ -0,0 +1,22 @@
+package com.baeldung.lambda.todo.config;
+
+public class Credentials {
+    private String username;
+    private String password;
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+}
@@ -0,0 +1,36 @@
+package com.baeldung.lambda.todo.config;
+
+import com.baeldung.lambda.todo.service.PostService;
+import com.baeldung.lambda.todo.service.ToDoReaderService;
+import com.google.inject.Guice;
+import com.google.inject.Injector;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ExecutionContext {
+    private static final Logger LOGGER =
+            LoggerFactory.getLogger(ExecutionContext.class);
+
+    private ToDoReaderService toDoReaderService;
+    private PostService postService;
+
+    public ExecutionContext() {
+        LOGGER.info("Loading configuration");
+
+        try {
+            Injector injector = Guice.createInjector(new Services());
+            this.toDoReaderService = injector.getInstance(ToDoReaderService.class);
+            this.postService = injector.getInstance(PostService.class);
+        } catch (Exception e) {
+            LOGGER.error("Could not start", e);
+        }
+    }
+
+    public ToDoReaderService getToDoReaderService() {
+        return toDoReaderService;
+    }
+
+    public PostService getPostService() {
+        return postService;
+    }
+}
@@ -0,0 +1,38 @@
+package com.baeldung.lambda.todo.config;
+
+import com.baeldung.lambda.todo.api.PostApi;
+import com.baeldung.lambda.todo.api.ToDoApi;
+import com.google.inject.AbstractModule;
+import feign.Feign;
+import feign.auth.BasicAuthRequestInterceptor;
+import feign.gson.GsonDecoder;
+import feign.gson.GsonEncoder;
+import feign.slf4j.Slf4jLogger;
+import uk.org.webcompere.lightweightconfig.ConfigLoader;
+
+import static feign.Logger.Level.FULL;
+
+public class Services extends AbstractModule {
+    @Override
+    protected void configure() {
+        Config config = ConfigLoader.loadYmlConfigFromResource("configuration.yml", Config.class);
+
+        ToDoApi toDoApi = Feign.builder()
+          .decoder(new GsonDecoder())
+          .logger(new Slf4jLogger())
+          .logLevel(FULL)
+          .requestInterceptor(new BasicAuthRequestInterceptor(config.getToDoCredentials().getUsername(), config.getToDoCredentials().getPassword()))
+          .target(ToDoApi.class, config.getToDoEndpoint());
+
+        PostApi postApi = Feign.builder()
+          .encoder(new GsonEncoder())
+          .logger(new Slf4jLogger())
+          .logLevel(FULL)
+          .requestInterceptor(new BasicAuthRequestInterceptor(config.getPostCredentials().getUsername(), config.getPostCredentials().getPassword()))
+          .target(PostApi.class, config.getPostEndpoint());
+
+        bind(Config.class).toInstance(config);
+        bind(ToDoApi.class).toInstance(toDoApi);
+        bind(PostApi.class).toInstance(postApi);
+    }
+}
@@ -0,0 +1,30 @@
+package com.baeldung.lambda.todo.service;
+
+import com.baeldung.lambda.todo.api.PostApi;
+import com.baeldung.lambda.todo.api.PostItem;
+import com.baeldung.lambda.todo.api.ToDoItem;
+import com.google.inject.Inject;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+
+public class PostService {
+    private static final Logger LOGGER = LogManager.getLogger(PostService.class);
+    private PostApi postApi;
+
+    @Inject
+    public PostService(PostApi postApi) {
+        this.postApi = postApi;
+    }
+
+    public void makePost(ToDoItem toDoItem) {
+        LOGGER.info("Posting about: {}", toDoItem);
+        PostItem item = new PostItem();
+        item.setTitle("To Do is Out Of Date: " + toDoItem.getId());
+        item.setUserId(toDoItem.getUserId());
+        item.setBody("Not done: " + toDoItem.getTitle());
+
+        LOGGER.info("Post: {}", item);
+        postApi.makePost(item);
+    }
+}
@@ -0,0 +1,30 @@
+package com.baeldung.lambda.todo.service;
+
+import com.baeldung.lambda.todo.api.ToDoApi;
+import com.baeldung.lambda.todo.api.ToDoItem;
+import com.baeldung.lambda.todo.config.Config;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import javax.inject.Inject;
+import java.util.Optional;
+
+public class ToDoReaderService {
+    // Log4j logger
+    private static final Logger LOGGER = LogManager.getLogger(ToDoReaderService.class);
+
+    private ToDoApi toDoApi;
+
+    @Inject
+    public ToDoReaderService(Config configuration, ToDoApi toDoApi) {
+        LOGGER.info("ToDo Endpoint on: {}", configuration.getToDoEndpoint());
+
+        this.toDoApi = toDoApi;
+    }
+
+    public Optional<ToDoItem> getOldestToDo() {
+        return toDoApi.getAllTodos().stream()
+          .filter(item -> !item.isCompleted())
+          .findFirst();
+    }
+}
@@ -0,0 +1,9 @@
+toDoEndpoint: https://jsonplaceholder.typicode.com
+postEndpoint: https://jsonplaceholder.typicode.com
+environmentName: ${ENV_NAME}
+toDoCredentials:
+  username: baeldung
+  password: ${TODO_PASSWORD:-password}
+postCredentials:
+  username: baeldung
+  password: ${POST_PASSWORD:-password}
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration packages="com.amazonaws.services.lambda.runtime.log4j2">
+    <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>
+    </Loggers>
+</Configuration>