Skip to content

Commit 0182484

Browse files
AntonKozlovAntonKozlov
committedFeb 16, 2022
Import blank-java
https://github.com/awsdocs/aws-lambda-developer-guide/tree/0efbd3a3e7ac9e83f689246b996bcc40a69b3281
1 parent 0552af2 commit 0182484

23 files changed

+723
-0
lines changed
 

‎1-create-bucket.sh

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
#!/bin/bash
2+
BUCKET_ID=$(dd if=/dev/random bs=8 count=1 2>/dev/null | od -An -tx1 | tr -d ' \t\n')
3+
BUCKET_NAME=lambda-artifacts-$BUCKET_ID
4+
echo $BUCKET_NAME > bucket-name.txt
5+
aws s3 mb s3://$BUCKET_NAME

‎2-build-layer.sh

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
#!/bin/bash
2+
set -eo pipefail
3+
gradle -q packageLibs
4+
mv build/distributions/blank-java.zip build/blank-java-lib.zip

‎3-deploy.sh

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
#!/bin/bash
2+
set -eo pipefail
3+
ARTIFACT_BUCKET=$(cat bucket-name.txt)
4+
TEMPLATE=template.yml
5+
if [ $1 ]
6+
then
7+
if [ $1 = mvn ]
8+
then
9+
TEMPLATE=template-mvn.yml
10+
mvn package
11+
fi
12+
else
13+
gradle build -i
14+
fi
15+
aws cloudformation package --template-file $TEMPLATE --s3-bucket $ARTIFACT_BUCKET --output-template-file out.yml
16+
aws cloudformation deploy --template-file out.yml --stack-name blank-java --capabilities CAPABILITY_NAMED_IAM

‎4-invoke.sh

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
#!/bin/bash
2+
set -eo pipefail
3+
FUNCTION=$(aws cloudformation describe-stack-resource --stack-name blank-java --logical-resource-id function --query 'StackResourceDetail.PhysicalResourceId' --output text)
4+
5+
while true; do
6+
aws lambda invoke --function-name $FUNCTION --payload file://event.json out.json
7+
cat out.json
8+
echo ""
9+
sleep 2
10+
done

‎5-cleanup.sh

+38
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
#!/bin/bash
2+
set -eo pipefail
3+
STACK=blank-java
4+
if [[ $# -eq 1 ]] ; then
5+
STACK=$1
6+
echo "Deleting stack $STACK"
7+
fi
8+
FUNCTION=$(aws cloudformation describe-stack-resource --stack-name $STACK --logical-resource-id function --query 'StackResourceDetail.PhysicalResourceId' --output text)
9+
aws cloudformation delete-stack --stack-name $STACK
10+
echo "Deleted $STACK stack."
11+
12+
if [ -f bucket-name.txt ]; then
13+
ARTIFACT_BUCKET=$(cat bucket-name.txt)
14+
if [[ ! $ARTIFACT_BUCKET =~ lambda-artifacts-[a-z0-9]{16} ]] ; then
15+
echo "Bucket was not created by this application. Skipping."
16+
else
17+
while true; do
18+
read -p "Delete deployment artifacts and bucket ($ARTIFACT_BUCKET)? (y/n)" response
19+
case $response in
20+
[Yy]* ) aws s3 rb --force s3://$ARTIFACT_BUCKET; rm bucket-name.txt; break;;
21+
[Nn]* ) break;;
22+
* ) echo "Response must start with y or n.";;
23+
esac
24+
done
25+
fi
26+
fi
27+
28+
while true; do
29+
read -p "Delete function log group (/aws/lambda/$FUNCTION)? (y/n)" response
30+
case $response in
31+
[Yy]* ) aws logs delete-log-group --log-group-name /aws/lambda/$FUNCTION; break;;
32+
[Nn]* ) break;;
33+
* ) echo "Response must start with y or n.";;
34+
esac
35+
done
36+
37+
rm -f out.yml out.json
38+
rm -rf build .gradle target

‎README.md

+96
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,96 @@
1+
# Blank function (Java)
2+
3+
![Architecture](/sample-apps/blank-java/images/sample-blank-java.png)
4+
5+
The project source includes function code and supporting resources:
6+
7+
- `src/main` - A Java function.
8+
- `src/test` - A unit test and helper classes.
9+
- `template.yml` - An AWS CloudFormation template that creates an application.
10+
- `build.gradle` - A Gradle build file.
11+
- `pom.xml` - A Maven build file.
12+
- `1-create-bucket.sh`, `2-build-layer.sh`, etc. - Shell scripts that use the AWS CLI to deploy and manage the application.
13+
14+
Use the following instructions to deploy the sample application.
15+
16+
# Requirements
17+
- [Java 8 runtime environment (SE JRE)](https://www.oracle.com/java/technologies/javase-downloads.html)
18+
- [Gradle 5](https://gradle.org/releases/) or [Maven 3](https://maven.apache.org/docs/history.html)
19+
- The Bash shell. For Linux and macOS, this is included by default. In Windows 10, you can install the [Windows Subsystem for Linux](https://docs.microsoft.com/en-us/windows/wsl/install-win10) to get a Windows-integrated version of Ubuntu and Bash.
20+
- [The AWS CLI](https://docs.aws.amazon.com/cli/latest/userguide/cli-chap-install.html) v1.17 or newer.
21+
22+
If you use the AWS CLI v2, add the following to your [configuration file](https://docs.aws.amazon.com/cli/latest/userguide/cli-configure-files.html) (`~/.aws/config`):
23+
24+
```
25+
cli_binary_format=raw-in-base64-out
26+
```
27+
28+
This setting enables the AWS CLI v2 to load JSON events from a file, matching the v1 behavior.
29+
30+
# Setup
31+
Download or clone this repository.
32+
33+
$ git clone https://github.com/awsdocs/aws-lambda-developer-guide.git
34+
$ cd aws-lambda-developer-guide/sample-apps/blank-java
35+
36+
To create a new bucket for deployment artifacts, run `1-create-bucket.sh`.
37+
38+
blank-java$ ./1-create-bucket.sh
39+
make_bucket: lambda-artifacts-a5e491dbb5b22e0d
40+
41+
To build a Lambda layer that contains the function's runtime dependencies, run `2-build-layer.sh`. Packaging dependencies in a layer reduces the size of the deployment package that you upload when you modify your code.
42+
43+
blank-java$ ./2-build-layer.sh
44+
45+
# Deploy
46+
47+
To deploy the application, run `3-deploy.sh`.
48+
49+
blank-java$ ./3-deploy.sh
50+
BUILD SUCCESSFUL in 1s
51+
Successfully packaged artifacts and wrote output template to file out.yml.
52+
Waiting for changeset to be created..
53+
Successfully created/updated stack - blank-java
54+
55+
This script uses AWS CloudFormation to deploy the Lambda functions and an IAM role. If the AWS CloudFormation stack that contains the resources already exists, the script updates it with any changes to the template or function code.
56+
57+
You can also build the application with Maven. To use maven, add `mvn` to the command.
58+
59+
java-basic$ ./3-deploy.sh mvn
60+
[INFO] Scanning for projects...
61+
[INFO] -----------------------< com.example:blank-java >-----------------------
62+
[INFO] Building blank-java-function 1.0-SNAPSHOT
63+
[INFO] --------------------------------[ jar ]---------------------------------
64+
...
65+
66+
# Test
67+
To invoke the function, run `4-invoke.sh`.
68+
69+
blank-java$ ./4-invoke.sh
70+
{
71+
"StatusCode": 200,
72+
"ExecutedVersion": "$LATEST"
73+
}
74+
75+
Let the script invoke the function a few times and then press `CRTL+C` to exit.
76+
77+
The application uses AWS X-Ray to trace requests. Open the [X-Ray console](https://console.aws.amazon.com/xray/home#/service-map) to view the service map.
78+
79+
![Service Map](/sample-apps/blank-java/images/blank-java-servicemap.png)
80+
81+
Choose a node in the main function graph. Then choose **View traces** to see a list of traces. Choose any trace to view a timeline that breaks down the work done by the function.
82+
83+
![Trace](/sample-apps/blank-java/images/blank-java-trace.png)
84+
85+
Finally, view the application in the Lambda console.
86+
87+
*To view the application*
88+
1. Open the [applications page](https://console.aws.amazon.com/lambda/home#/applications) in the Lambda console.
89+
2. Choose **blank-java**.
90+
91+
![Application](/sample-apps/blank-java/images/blank-java-application.png)
92+
93+
# Cleanup
94+
To delete the application, run `5-cleanup.sh`.
95+
96+
blank$ ./5-cleanup.sh

‎build.gradle

+60
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
plugins {
2+
id 'java'
3+
}
4+
5+
repositories {
6+
mavenCentral()
7+
}
8+
9+
dependencies {
10+
implementation platform('software.amazon.awssdk:bom:2.10.73')
11+
implementation platform('com.amazonaws:aws-xray-recorder-sdk-bom:2.4.0')
12+
implementation 'software.amazon.awssdk:lambda'
13+
implementation 'com.amazonaws:aws-xray-recorder-sdk-core'
14+
implementation 'com.amazonaws:aws-xray-recorder-sdk-aws-sdk-core'
15+
implementation 'com.amazonaws:aws-xray-recorder-sdk-aws-sdk-v2'
16+
implementation 'com.amazonaws:aws-xray-recorder-sdk-aws-sdk-v2-instrumentor'
17+
implementation 'com.amazonaws:aws-lambda-java-core:1.2.1'
18+
implementation 'com.amazonaws:aws-lambda-java-events:2.2.9'
19+
implementation 'com.google.code.gson:gson:2.8.6'
20+
implementation 'org.apache.logging.log4j:log4j-api:[2.17.1,)'
21+
implementation 'org.apache.logging.log4j:log4j-core:[2.17.1,)'
22+
runtimeOnly 'org.apache.logging.log4j:log4j-slf4j18-impl:[2.17.1,)'
23+
runtimeOnly 'com.amazonaws:aws-lambda-java-log4j2:1.5.0'
24+
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.6.0'
25+
testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.6.0'
26+
}
27+
28+
test {
29+
useJUnitPlatform()
30+
}
31+
32+
task packageFat(type: Zip) {
33+
from compileJava
34+
from processResources
35+
into('lib') {
36+
from configurations.runtimeClasspath
37+
}
38+
dirMode = 0755
39+
fileMode = 0755
40+
}
41+
42+
task packageLibs(type: Zip) {
43+
into('java/lib') {
44+
from configurations.runtimeClasspath
45+
}
46+
dirMode = 0755
47+
fileMode = 0755
48+
}
49+
50+
task packageSkinny(type: Zip) {
51+
from compileJava
52+
from processResources
53+
}
54+
55+
java {
56+
sourceCompatibility = JavaVersion.VERSION_1_8
57+
targetCompatibility = JavaVersion.VERSION_1_8
58+
}
59+
60+
build.dependsOn packageSkinny

‎event.json

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
{
2+
"Records": [
3+
{
4+
"messageId": "19dd0b57-b21e-4ac1-bd88-01bbb068cb78",
5+
"receiptHandle": "MessageReceiptHandle",
6+
"body": "Hello from SQS!",
7+
"attributes": {
8+
"ApproximateReceiveCount": "1",
9+
"SentTimestamp": "1523232000000",
10+
"SenderId": "123456789012",
11+
"ApproximateFirstReceiveTimestamp": "1523232000001"
12+
},
13+
"messageAttributes": {},
14+
"md5OfBody": "7b270e59b47ff90a553787216d55d91d",
15+
"eventSource": "aws:sqs",
16+
"eventSourceARN": "arn:aws:sqs:us-west-2:123456789012:MyQueue",
17+
"awsRegion": "us-west-2"
18+
}
19+
]
20+
}

‎images/blank-java-application.png

40.2 KB
Loading

‎images/blank-java-servicemap.png

19.6 KB
Loading

‎images/blank-java-trace.png

29.2 KB
Loading

‎images/sample-blank-java.png

48.5 KB
Loading

‎pom.xml

+136
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,136 @@
1+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
2+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
3+
<modelVersion>4.0.0</modelVersion>
4+
<groupId>com.example</groupId>
5+
<artifactId>blank-java</artifactId>
6+
<packaging>jar</packaging>
7+
<version>1.0-SNAPSHOT</version>
8+
<name>blank-java-function</name>
9+
<properties>
10+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
11+
<maven.compiler.source>1.8</maven.compiler.source>
12+
<maven.compiler.target>1.8</maven.compiler.target>
13+
</properties>
14+
<dependencies>
15+
<dependency>
16+
<groupId>com.amazonaws</groupId>
17+
<artifactId>aws-lambda-java-core</artifactId>
18+
<version>1.2.1</version>
19+
</dependency>
20+
<dependency>
21+
<groupId>com.amazonaws</groupId>
22+
<artifactId>aws-lambda-java-events</artifactId>
23+
<version>2.2.9</version>
24+
</dependency>
25+
<dependency>
26+
<groupId>com.amazonaws</groupId>
27+
<artifactId>aws-lambda-java-log4j2</artifactId>
28+
<version>1.5.0</version>
29+
</dependency>
30+
<dependency>
31+
<groupId>com.google.code.gson</groupId>
32+
<artifactId>gson</artifactId>
33+
<version>2.8.6</version>
34+
</dependency>
35+
<dependency>
36+
<groupId>org.apache.logging.log4j</groupId>
37+
<artifactId>log4j-api</artifactId>
38+
<version>[2.17.1,)</version>
39+
</dependency>
40+
<dependency>
41+
<groupId>org.apache.logging.log4j</groupId>
42+
<artifactId>log4j-core</artifactId>
43+
<version>[2.17.1,)</version>
44+
</dependency>
45+
<dependency>
46+
<groupId>org.apache.logging.log4j</groupId>
47+
<artifactId>log4j-slf4j18-impl</artifactId>
48+
<version>[2.17.1,)</version>
49+
</dependency>
50+
<dependency>
51+
<groupId>software.amazon.awssdk</groupId>
52+
<artifactId>lambda</artifactId>
53+
<version>2.10.72</version>
54+
</dependency>
55+
<dependency>
56+
<groupId>com.amazonaws</groupId>
57+
<artifactId>aws-xray-recorder-sdk-core</artifactId>
58+
<version>2.4.0</version>
59+
</dependency>
60+
<dependency>
61+
<groupId>com.amazonaws</groupId>
62+
<artifactId>aws-xray-recorder-sdk-aws-sdk-core</artifactId>
63+
<version>2.4.0</version>
64+
</dependency>
65+
<dependency>
66+
<groupId>com.amazonaws</groupId>
67+
<artifactId>aws-xray-recorder-sdk-aws-sdk-v2</artifactId>
68+
<version>2.4.0</version>
69+
</dependency>
70+
<dependency>
71+
<groupId>com.amazonaws</groupId>
72+
<artifactId>aws-xray-recorder-sdk-aws-sdk-v2-instrumentor</artifactId>
73+
<version>2.4.0</version>
74+
</dependency>
75+
<dependency>
76+
<groupId>org.junit.jupiter</groupId>
77+
<artifactId>junit-jupiter-api</artifactId>
78+
<version>5.6.0</version>
79+
<scope>test</scope>
80+
</dependency>
81+
<dependency>
82+
<groupId>org.junit.jupiter</groupId>
83+
<artifactId>junit-jupiter-engine</artifactId>
84+
<version>5.6.0</version>
85+
<scope>test</scope>
86+
</dependency>
87+
88+
</dependencies>
89+
90+
<build>
91+
<plugins>
92+
<plugin>
93+
<artifactId>maven-surefire-plugin</artifactId>
94+
<version>2.22.2</version>
95+
</plugin>
96+
<plugin>
97+
<groupId>org.apache.maven.plugins</groupId>
98+
<artifactId>maven-shade-plugin</artifactId>
99+
<version>3.2.2</version>
100+
<configuration>
101+
<createDependencyReducedPom>false</createDependencyReducedPom>
102+
</configuration>
103+
<executions>
104+
<execution>
105+
<phase>package</phase>
106+
<goals>
107+
<goal>shade</goal>
108+
</goals>
109+
<configuration>
110+
<transformers>
111+
<transformer implementation="com.github.edwgiz.maven_shade_plugin.log4j2_cache_transformer.PluginsCacheFileTransformer">
112+
</transformer>
113+
</transformers>
114+
</configuration>
115+
</execution>
116+
</executions>
117+
<dependencies>
118+
<dependency>
119+
<groupId>com.github.edwgiz</groupId>
120+
<artifactId>maven-shade-plugin.log4j2-cachefile-transformer</artifactId>
121+
<version>[2.17.1,)</version>
122+
</dependency>
123+
</dependencies>
124+
</plugin>
125+
<plugin>
126+
<groupId>org.apache.maven.plugins</groupId>
127+
<artifactId>maven-compiler-plugin</artifactId>
128+
<version>3.8.1</version>
129+
<configuration>
130+
<source>1.8</source>
131+
<target>1.8</target>
132+
</configuration>
133+
</plugin>
134+
</plugins>
135+
</build>
136+
</project>

‎src/main/java/example/Handler.java

+65
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,65 @@
1+
package example;
2+
3+
import com.amazonaws.services.lambda.runtime.Context;
4+
import com.amazonaws.services.lambda.runtime.LambdaLogger;
5+
import com.amazonaws.services.lambda.runtime.RequestHandler;
6+
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
7+
import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
8+
9+
import software.amazon.awssdk.services.lambda.model.GetAccountSettingsRequest;
10+
import software.amazon.awssdk.services.lambda.model.GetAccountSettingsResponse;
11+
import software.amazon.awssdk.services.lambda.model.ServiceException;
12+
import software.amazon.awssdk.services.lambda.LambdaAsyncClient;
13+
import software.amazon.awssdk.services.lambda.model.AccountUsage;
14+
15+
import com.google.gson.Gson;
16+
import com.google.gson.GsonBuilder;
17+
18+
import org.slf4j.Logger;
19+
import org.slf4j.LoggerFactory;
20+
21+
import java.lang.StringBuilder;
22+
import java.util.Map;
23+
import java.util.List;
24+
import java.util.concurrent.CompletableFuture;
25+
26+
// Handler value: example.Handler
27+
public class Handler implements RequestHandler<SQSEvent, String>{
28+
private static final Logger logger = LoggerFactory.getLogger(Handler.class);
29+
private static final Gson gson = new GsonBuilder().setPrettyPrinting().create();
30+
private static final LambdaAsyncClient lambdaClient = LambdaAsyncClient.create();
31+
public Handler(){
32+
CompletableFuture<GetAccountSettingsResponse> accountSettings = lambdaClient.getAccountSettings(GetAccountSettingsRequest.builder().build());
33+
try {
34+
GetAccountSettingsResponse settings = accountSettings.get();
35+
} catch(Exception e) {
36+
e.getStackTrace();
37+
}
38+
}
39+
@Override
40+
public String handleRequest(SQSEvent event, Context context)
41+
{
42+
String response = new String();
43+
// call Lambda API
44+
logger.info("Getting account settings");
45+
CompletableFuture<GetAccountSettingsResponse> accountSettings =
46+
lambdaClient.getAccountSettings(GetAccountSettingsRequest.builder().build());
47+
// log execution details
48+
logger.info("ENVIRONMENT VARIABLES: {}", gson.toJson(System.getenv()));
49+
logger.info("CONTEXT: {}", gson.toJson(context));
50+
logger.info("EVENT: {}", gson.toJson(event));
51+
// process event
52+
for(SQSMessage msg : event.getRecords()){
53+
logger.info(msg.getBody());
54+
}
55+
// process Lambda API response
56+
try {
57+
GetAccountSettingsResponse settings = accountSettings.get();
58+
response = gson.toJson(settings.accountUsage());
59+
logger.info("Account usage: {}", response);
60+
} catch(Exception e) {
61+
e.getStackTrace();
62+
}
63+
return response;
64+
}
65+
}

‎src/main/resources/log4j2.xml

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
<Configuration status="WARN">
2+
<Appenders>
3+
<Lambda name="Lambda">
4+
<PatternLayout>
5+
<pattern>%d{yyyy-MM-dd HH:mm:ss} %X{AWSRequestId} %-5p %c{1} - %m%n</pattern>
6+
</PatternLayout>
7+
</Lambda>
8+
</Appenders>
9+
<Loggers>
10+
<Root level="INFO">
11+
<AppenderRef ref="Lambda"/>
12+
</Root>
13+
<Logger name="software.amazon.awssdk" level="WARN" />
14+
<Logger name="software.amazon.awssdk.request" level="DEBUG" />
15+
</Loggers>
16+
</Configuration>

‎src/test/java/example/InvokeTest.java

+71
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,71 @@
1+
package example;
2+
3+
import static org.junit.jupiter.api.Assertions.assertEquals;
4+
import static org.junit.jupiter.api.Assertions.assertTrue;
5+
import org.junit.jupiter.api.Test;
6+
7+
import com.amazonaws.services.lambda.runtime.Context;
8+
import com.amazonaws.services.lambda.runtime.LambdaLogger;
9+
import com.amazonaws.services.lambda.runtime.RequestHandler;
10+
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
11+
import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
12+
13+
import com.google.gson.Gson;
14+
import com.google.gson.GsonBuilder;
15+
16+
import org.slf4j.Logger;
17+
import org.slf4j.LoggerFactory;
18+
19+
import java.util.List;
20+
import java.util.ArrayList;
21+
import java.io.IOException;
22+
import java.nio.charset.StandardCharsets;
23+
import java.nio.file.Files;
24+
import java.nio.file.Paths;
25+
import java.util.stream.Stream;
26+
27+
import com.amazonaws.xray.AWSXRay;
28+
import com.amazonaws.xray.AWSXRayRecorderBuilder;
29+
import com.amazonaws.xray.strategy.sampling.NoSamplingStrategy;
30+
31+
class InvokeTest {
32+
private static final Logger logger = LoggerFactory.getLogger(InvokeTest.class);
33+
Gson gson = new GsonBuilder()
34+
.registerTypeAdapter(SQSEvent.class, new SQSEventDeserializer())
35+
.setPrettyPrinting()
36+
.create();
37+
38+
public InvokeTest() {
39+
AWSXRayRecorderBuilder builder = AWSXRayRecorderBuilder.standard();
40+
builder.withSamplingStrategy(new NoSamplingStrategy());
41+
AWSXRay.setGlobalRecorder(builder.build());
42+
}
43+
44+
@Test
45+
void invokeTest() {
46+
AWSXRay.beginSegment("blank-java-test");
47+
String path = "src/test/resources/event.json";
48+
String eventString = loadJsonFile(path);
49+
SQSEvent event = gson.fromJson(eventString, SQSEvent.class);
50+
Context context = new TestContext();
51+
String requestId = context.getAwsRequestId();
52+
Handler handler = new Handler();
53+
String result = handler.handleRequest(event, context);
54+
assertTrue(result.contains("totalCodeSize"));
55+
AWSXRay.endSegment();
56+
}
57+
58+
private static String loadJsonFile(String path)
59+
{
60+
StringBuilder stringBuilder = new StringBuilder();
61+
try (Stream<String> stream = Files.lines( Paths.get(path), StandardCharsets.UTF_8))
62+
{
63+
stream.forEach(s -> stringBuilder.append(s));
64+
}
65+
catch (IOException e)
66+
{
67+
e.printStackTrace();
68+
}
69+
return stringBuilder.toString();
70+
}
71+
}

‎src/test/java/example/SQSEventDeserializer.java

+42
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
package example;
2+
3+
import com.amazonaws.services.lambda.runtime.LambdaLogger;
4+
import com.amazonaws.services.lambda.runtime.RequestHandler;
5+
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
6+
import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
7+
8+
import com.google.gson.Gson;
9+
import com.google.gson.GsonBuilder;
10+
import com.google.gson.JsonElement;
11+
import com.google.gson.JsonArray;
12+
import com.google.gson.JsonObject;
13+
import com.google.gson.JsonDeserializationContext;
14+
import com.google.gson.JsonParseException;
15+
import com.google.gson.JsonDeserializer;
16+
import com.google.gson.reflect.TypeToken;
17+
18+
import org.slf4j.Logger;
19+
import org.slf4j.LoggerFactory;
20+
21+
import java.util.List;
22+
import java.util.ArrayList;
23+
import java.lang.reflect.Type;
24+
25+
public class SQSEventDeserializer implements JsonDeserializer<SQSEvent> {
26+
private static final Logger logger = LoggerFactory.getLogger(InvokeTest.class);
27+
Gson gson = new GsonBuilder().setPrettyPrinting().create();
28+
Type sqsMessageArray = new TypeToken<ArrayList<SQSMessage>>(){}.getType();
29+
30+
@Override
31+
public SQSEvent deserialize(JsonElement eventJson, Type typeOfT, JsonDeserializationContext context)
32+
throws JsonParseException {
33+
SQSEvent event = new SQSEvent();
34+
logger.info("DESERIALIZING TEST EVENT");
35+
logger.info("EVENT JSON: " + eventJson.toString());
36+
// Records key is capitalized in test event, but lowercase in type
37+
JsonArray recordsArray = eventJson.getAsJsonObject().get("Records").getAsJsonArray();
38+
ArrayList<SQSMessage> records = gson.fromJson(recordsArray, sqsMessageArray);
39+
event.setRecords(records);
40+
return event;
41+
}
42+
}

‎src/test/java/example/TestContext.java

+45
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
package example;
2+
3+
import com.amazonaws.services.lambda.runtime.Context;
4+
import com.amazonaws.services.lambda.runtime.CognitoIdentity;
5+
import com.amazonaws.services.lambda.runtime.ClientContext;
6+
import com.amazonaws.services.lambda.runtime.LambdaLogger;
7+
8+
public class TestContext implements Context{
9+
10+
public TestContext() {}
11+
public String getAwsRequestId(){
12+
return new String("495b12a8-xmpl-4eca-8168-160484189f99");
13+
}
14+
public String getLogGroupName(){
15+
return new String("/aws/lambda/my-function");
16+
}
17+
public String getLogStreamName(){
18+
return new String("2020/02/26/[$LATEST]704f8dxmpla04097b9134246b8438f1a");
19+
}
20+
public String getFunctionName(){
21+
return new String("my-function");
22+
}
23+
public String getFunctionVersion(){
24+
return new String("$LATEST");
25+
}
26+
public String getInvokedFunctionArn(){
27+
return new String("arn:aws:lambda:us-east-2:123456789012:function:my-function");
28+
}
29+
public CognitoIdentity getIdentity(){
30+
return null;
31+
}
32+
public ClientContext getClientContext(){
33+
return null;
34+
}
35+
public int getRemainingTimeInMillis(){
36+
return 300000;
37+
}
38+
public int getMemoryLimitInMB(){
39+
return 512;
40+
}
41+
public LambdaLogger getLogger(){
42+
return new TestLogger();
43+
}
44+
45+
}

‎src/test/java/example/TestLogger.java

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
package example;
2+
import org.slf4j.Logger;
3+
import org.slf4j.LoggerFactory;
4+
import com.amazonaws.services.lambda.runtime.LambdaLogger;
5+
6+
public class TestLogger implements LambdaLogger {
7+
private static final Logger logger = LoggerFactory.getLogger(TestLogger.class);
8+
public TestLogger(){}
9+
public void log(String message){
10+
logger.info(message);
11+
}
12+
public void log(byte[] message){
13+
logger.info(new String(message));
14+
}
15+
}

‎src/test/resources/event.json

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
{
2+
"Records": [
3+
{
4+
"messageId": "19dd0b57-b21e-4ac1-bd88-01bbb068cb78",
5+
"receiptHandle": "MessageReceiptHandle",
6+
"body": "Hello from SQS!",
7+
"attributes": {
8+
"ApproximateReceiveCount": "1",
9+
"SentTimestamp": "1523232000000",
10+
"SenderId": "123456789012",
11+
"ApproximateFirstReceiveTimestamp": "1523232000001"
12+
},
13+
"messageAttributes": {},
14+
"md5OfBody": "7b270e59b47ff90a553787216d55d91d",
15+
"eventSource": "aws:sqs",
16+
"eventSourceARN": "arn:aws:sqs:us-west-2:123456789012:MyQueue",
17+
"awsRegion": "us-west-2"
18+
}
19+
]
20+
}

‎src/test/resources/log4j2.xml

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
<Configuration status="WARN">
2+
<Appenders>
3+
<Console name="ConsoleAppender" target="SYSTEM_OUT">
4+
<PatternLayout pattern="%d{YYYY-MM-dd HH:mm:ss} [%t] %-5p %c:%L - %m%n" />
5+
</Console>
6+
</Appenders>
7+
<Loggers>
8+
<Root level="INFO">
9+
<AppenderRef ref="ConsoleAppender"/>
10+
</Root>
11+
<Logger name="software.amazon.awssdk" level="WARN" />
12+
<Logger name="software.amazon.awssdk.request" level="DEBUG" />
13+
</Loggers>
14+
</Configuration>

‎template-mvn.yml

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
AWSTemplateFormatVersion: '2010-09-09'
2+
Transform: 'AWS::Serverless-2016-10-31'
3+
Description: An AWS Lambda application that calls the Lambda API.
4+
Resources:
5+
function:
6+
Type: AWS::Serverless::Function
7+
Properties:
8+
CodeUri: target/blank-java-1.0-SNAPSHOT.jar
9+
Handler: example.Handler::handleRequest
10+
Runtime: java8
11+
Description: Java function
12+
MemorySize: 512
13+
Timeout: 10
14+
# Function's execution role
15+
Policies:
16+
- AWSLambdaBasicExecutionRole
17+
- AWSLambda_ReadOnlyAccess
18+
- AWSXrayWriteOnlyAccess
19+
- AWSLambdaVPCAccessExecutionRole
20+
Tracing: Active

‎template.yml

+30
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
AWSTemplateFormatVersion: '2010-09-09'
2+
Transform: 'AWS::Serverless-2016-10-31'
3+
Description: An AWS Lambda application that calls the Lambda API.
4+
Resources:
5+
function:
6+
Type: AWS::Serverless::Function
7+
Properties:
8+
CodeUri: build/distributions/blank-java.zip
9+
Handler: example.Handler::handleRequest
10+
Runtime: java8
11+
Description: Java function
12+
MemorySize: 512
13+
Timeout: 10
14+
# Function's execution role
15+
Policies:
16+
- AWSLambdaBasicExecutionRole
17+
- AWSLambda_ReadOnlyAccess
18+
- AWSXrayWriteOnlyAccess
19+
- AWSLambdaVPCAccessExecutionRole
20+
Tracing: Active
21+
Layers:
22+
- !Ref libs
23+
libs:
24+
Type: AWS::Serverless::LayerVersion
25+
Properties:
26+
LayerName: blank-java-lib
27+
Description: Dependencies for the blank-java sample app.
28+
ContentUri: build/blank-java-lib.zip
29+
CompatibleRuntimes:
30+
- java8

0 commit comments

Comments
 (0)
Please sign in to comment.