/jdk-17/

/.idea/

/example/software/ExampleFunction/target/

/opt/jdk-17/bin/java -cp aws-lambda-java-runtime-interface-client-1.1.0.jar com.amazonaws.services.lambda.runtime.api.client.AWSLambda "$_HANDLER"

{

"app": "mvn -e -q compile exec:java",

"context": {

"@aws-cdk/core:enableStackNameDuplicates": "true",

"aws-cdk:enableDiffNoFail": "true",

"@aws-cdk/core:stackRelativeExports": "true",

"@aws-cdk/aws-ecr-assets:dockerIgnoreSupport": true,

"@aws-cdk/aws-secretsmanager:parseOwnedSecretName": true,

"@aws-cdk/aws-kms:defaultKeyPolicies": true,

"@aws-cdk/aws-s3:grantWriteWithoutAcl": true

}

}

config:

phases:

- duration: 300

arrivalRate: 120

scenarios:

- flow:

- get:

url: "{{ url }}"

<?xml version="1.0" encoding="UTF-8"?>

<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"

xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

<modelVersion>4.0.0</modelVersion>

<groupId>example</groupId>

<artifactId>infrastructure</artifactId>

<version>0.1</version>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<cdk.version>1.87.1</cdk.version>

<junit.version>5.7.0</junit.version>

</properties>

<build>

<plugins>

<plugin>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-compiler-plugin</artifactId>

<version>3.8.1</version>

<configuration>

<source>9</source>

<target>9</target>

</configuration>

</plugin>

<plugin>

<groupId>org.codehaus.mojo</groupId>

<artifactId>exec-maven-plugin</artifactId>

<version>3.0.0</version>

<configuration>

<mainClass>example.InfrastructureApp</mainClass>

</configuration>

</plugin>

</plugins>

</build>

<dependencies>

<!-- AWS Cloud Development Kit -->

<dependency>

<groupId>software.amazon.awscdk</groupId>

<artifactId>core</artifactId>

<version>${cdk.version}</version>

</dependency>

<dependency>

<groupId>software.amazon.awscdk</groupId>

<artifactId>lambda</artifactId>

<version>${cdk.version}</version>

</dependency>

<dependency>

<groupId>software.amazon.awscdk</groupId>

<artifactId>apigatewayv2</artifactId>

<version>${cdk.version}</version>

</dependency>

<dependency>

<groupId>software.amazon.awscdk</groupId>

<artifactId>apigatewayv2-integrations</artifactId>

<version>${cdk.version}</version>

</dependency>

<dependency>

<groupId>software.amazon.awscdk</groupId>

<artifactId>dynamodb</artifactId>

<version>${cdk.version}</version>

</dependency>

</dependencies>

</project>

package example;

import software.amazon.awscdk.core.App;

public class InfrastructureApp {

public static void main(final String[] args) {

App app = new App();

new InfrastructureStack(app, "InfrastructureStack");

app.synth();

}

}

package example;

import software.amazon.awscdk.core.CfnOutput;

import software.amazon.awscdk.core.CfnOutputProps;

import software.amazon.awscdk.core.Construct;

import software.amazon.awscdk.core.Duration;

import software.amazon.awscdk.core.Stack;

import software.amazon.awscdk.core.StackProps;

import software.amazon.awscdk.services.apigatewayv2.AddRoutesOptions;

import software.amazon.awscdk.services.apigatewayv2.HttpApi;

import software.amazon.awscdk.services.apigatewayv2.HttpApiProps;

import software.amazon.awscdk.services.apigatewayv2.HttpMethod;

import software.amazon.awscdk.services.apigatewayv2.PayloadFormatVersion;

import software.amazon.awscdk.services.apigatewayv2.integrations.LambdaProxyIntegration;

import software.amazon.awscdk.services.apigatewayv2.integrations.LambdaProxyIntegrationProps;

import software.amazon.awscdk.services.dynamodb.Attribute;

import software.amazon.awscdk.services.dynamodb.AttributeType;

import software.amazon.awscdk.services.dynamodb.BillingMode;

import software.amazon.awscdk.services.dynamodb.Table;

import software.amazon.awscdk.services.dynamodb.TableProps;

import software.amazon.awscdk.services.lambda.Code;

import software.amazon.awscdk.services.lambda.Function;

import software.amazon.awscdk.services.lambda.FunctionProps;

import software.amazon.awscdk.services.lambda.LayerVersion;

import software.amazon.awscdk.services.lambda.LayerVersionProps;

import software.amazon.awscdk.services.lambda.Runtime;

import software.amazon.awscdk.services.logs.RetentionDays;

import java.util.Arrays;

import java.util.HashMap;

import java.util.Map;

import static java.util.Collections.singletonList;

public class InfrastructureStack extends Stack {

public InfrastructureStack(final Construct scope, final String id) {

this(scope, id, null);

}

public InfrastructureStack(final Construct scope, final String id, final StackProps props) {

super(scope, id, props);

Table exampleTable = new Table(this, "ExampleTable", TableProps.builder()

.partitionKey(Attribute.builder()

.type(AttributeType.STRING)

.name("id").build())

.billingMode(BillingMode.PAY_PER_REQUEST)

.build());

LayerVersion java17layer = new LayerVersion(this, "Java17Layer", LayerVersionProps.builder()

.layerVersionName("Java17Layer")

.description("Java 17")

.compatibleRuntimes(Arrays.asList(Runtime.PROVIDED_AL2))

.code(Code.fromAsset("../../java17layer.zip"))

.build());

Function exampleWithLayer = new Function(this, "ExampleWithLayer", FunctionProps.builder()

.functionName("example-with-layer")

.description("example-with-layer")

.handler("example.ExampleDynamoDbHandler::handleRequest")

.runtime(Runtime.PROVIDED_AL2)

.code(Code.fromAsset("../software/ExampleFunction/target/example.jar"))

.memorySize(512)

.environment(mapOf("TABLE_NAME", exampleTable.getTableName()))

.timeout(Duration.seconds(20))

.logRetention(RetentionDays.ONE_WEEK)

.layers(singletonList(java17layer))

.build());

exampleTable.grantWriteData(exampleWithLayer);

HttpApi httpApi = new HttpApi(this, "ExampleApi", HttpApiProps.builder()

.apiName("ExampleApi")

.build());

httpApi.addRoutes(AddRoutesOptions.builder()

.path("/with")

.methods(singletonList(HttpMethod.GET))

.integration(new LambdaProxyIntegration(LambdaProxyIntegrationProps.builder()

.handler(exampleWithLayer)

.payloadFormatVersion(PayloadFormatVersion.VERSION_2_0)

.build()))

.build());

new CfnOutput(this, "api-endpoint", CfnOutputProps.builder()

.value(httpApi.getApiEndpoint())

.build());

}

private Map<String, String> mapOf(String... keyValues) {

Map<String, String> map = new HashMap<>(keyValues.length/2);

for (int i = 0; i < keyValues.length; i++) {

if(i % 2 == 0) {

map.put(keyValues[i], keyValues[i + 1]);

}

}

return map;

}

}

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>example</groupId>

<artifactId>example</artifactId>

<version>1.0</version>

<packaging>jar</packaging>

<name>A sample Lambda function created for SAM CLI.</name>

<properties>

<aws.java.sdk.version>2.16.1</aws.java.sdk.version>

</properties>

<dependencyManagement>

<dependencies>

<dependency>

<groupId>software.amazon.awssdk</groupId>

<artifactId>bom</artifactId>

<version>${aws.java.sdk.version}</version>

<type>pom</type>

<scope>import</scope>

</dependency>

</dependencies>

</dependencyManagement>

<dependencies>

<dependency>

<groupId>com.amazonaws</groupId>

<artifactId>aws-lambda-java-core</artifactId>

<version>1.2.1</version>

</dependency>

<dependency>

<groupId>com.amazonaws</groupId>

<artifactId>aws-lambda-java-events</artifactId>

<version>3.6.0</version>

</dependency>

<dependency>

<groupId>software.amazon.awssdk</groupId>

<artifactId>dynamodb</artifactId>

<exclusions>

<exclusion>

<groupId>software.amazon.awssdk</groupId>

<artifactId>netty-nio-client</artifactId>

</exclusion>

<exclusion>

<groupId>software.amazon.awssdk</groupId>

<artifactId>apache-client</artifactId>

</exclusion>

</exclusions>

</dependency>

<dependency>

<groupId>software.amazon.awssdk</groupId>

<artifactId>url-connection-client</artifactId>

</dependency>

</dependencies>

<build>

<plugins>

<plugin>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-shade-plugin</artifactId>

<version>3.2.4</version>

<configuration>

<finalName>example</finalName>

</configuration>

<executions>

<execution>

<phase>package</phase>

<goals>

<goal>shade</goal>

</goals>

</execution>

</executions>

</plugin>

<plugin>

<groupId>org.apache.maven.plugins</groupId>

<artifactId>maven-compiler-plugin</artifactId>

<version>3.8.1</version>

<configuration>

<source>1.8</source>

<target>1.8</target>

</configuration>

</plugin>

</plugins>

</build>

</project>

package example;

import com.amazonaws.services.lambda.runtime.Context;

import com.amazonaws.services.lambda.runtime.RequestHandler;

import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyRequestEvent;

import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyResponseEvent;

import software.amazon.awssdk.auth.credentials.EnvironmentVariableCredentialsProvider;

import software.amazon.awssdk.core.SdkSystemSetting;

import software.amazon.awssdk.http.urlconnection.UrlConnectionHttpClient;

import software.amazon.awssdk.regions.Region;

import software.amazon.awssdk.services.dynamodb.DynamoDbClient;

import software.amazon.awssdk.services.dynamodb.model.AttributeValue;

import software.amazon.awssdk.services.dynamodb.model.DynamoDbException;

import software.amazon.awssdk.services.dynamodb.model.PutItemRequest;

import java.util.HashMap;

import java.util.Map;

import java.util.UUID;

import java.util.stream.Collectors;

public class ExampleDynamoDbHandler implements RequestHandler<APIGatewayProxyRequestEvent, APIGatewayProxyResponseEvent> {

private static final String TABLE_NAME = System.getenv("TABLE_NAME");

private final DynamoDbClient dynamoDbClient = DynamoDbClient.builder()

.credentialsProvider(EnvironmentVariableCredentialsProvider.create())

.region(Region.of(System.getenv(SdkSystemSetting.AWS_REGION.environmentVariable())))

.httpClientBuilder(UrlConnectionHttpClient.builder())

.build();

public APIGatewayProxyResponseEvent handleRequest(final APIGatewayProxyRequestEvent input, final Context context) {

APIGatewayProxyResponseEvent response = new APIGatewayProxyResponseEvent();

context.getLogger().log(input.toString());

try {

Map<String, AttributeValue> itemAttributes = new HashMap<>();

itemAttributes.put("id", AttributeValue.builder().s(context.getAwsRequestId()).build());

itemAttributes.put("value",

AttributeValue.builder().s(

input.getHeaders().entrySet()

.stream()

.map(a -> a.getKey()+"="+a.getValue())

.collect(Collectors.joining())

).build()

);

dynamoDbClient.putItem(PutItemRequest.builder()

.tableName(TABLE_NAME)

.item(itemAttributes)

.build());

return response.withBody("successful").withStatusCode(200);

} catch (DynamoDbException e) {

context.getLogger().log(e.getMessage());

return response.withBody("error").withStatusCode(500);

}

}

}

curl -4 -L https://download.java.net/java/GA/jdk17/0d483333a00540d886896bac774ff48b/35/GPL/openjdk-17_linux-x64_bin.tar.gz | tar -xvz

curl -4 -L https://repo.maven.apache.org/maven2/com/amazonaws/aws-lambda-java-runtime-interface-client/1.1.0/aws-lambda-java-runtime-interface-client-1.1.0.jar -o aws-lambda-java-runtime-interface-client-1.1.0.jar

chmod 755 bootstrap && zip -r java17layer.zip jdk-17 bootstrap aws-lambda-java-runtime-interface-client-1.1.0.jar