Initial commit

Author: Ubuntu

README.md

@@ -22,6 +22,7 @@ If you'd like to jump right into code, you can begin with a starter project in y
 - [Java starter](./java-test-samples/apigw-lambda-list-s3-buckets)
 - [TypeScript starter](./typescript-test-samples/typescript-test-intro)
 - [.NET starter](./dotnet-test-samples/apigw-lambda-list-s3-buckets)
+- [Local starter](./local-test-samples/apigateway-crud-lambda-dynamodb)
 
 # Language Directories
 The repository is divided into several language directories. If you would like to browse by language, you can navigate to the main page of each language directory:
@@ -30,6 +31,8 @@ The repository is divided into several language directories. If you would like t
 - [Java main directory](./java-test-samples/)
 - [TypeScript main directory](./typescript-test-samples/)
 - [.NET main directory](./dotnet-test-samples/)
+- [Local starter](./local-test-samples/)
+
 
 # Workload Types
 This repository contains sample code for testing a variety of different types of workloads, including API's, Event-Driven Architectures, Service Orchestration, Data Processing, and AWS Partner Patterns.
@@ -45,6 +48,8 @@ This repository contains sample code for testing a variety of different types of
 | [API Gateway, Lambda Authorizer, Lambda, DynamoDB](https://github.com/aws-samples/serverless-samples/tree/main/serverless-rest-api/javascript-http-sam) [External] | Node.js |
 | [API Gateway, Lambda, S3](./dotnet-test-samples/apigw-lambda-list-s3-buckets)|.NET|
 | [API Gateway, Lambda, DynamoDB](./dotnet-test-samples/apigw-lambda-ddb)|.NET|
+| [Api Gateway, Lambda, DynamoDB](./local-test-samples/apigateway-crud-lambda-dynamodb)|Local|
+| [Api Gateway, MOCK](./local-test-samples/apigateway-mock)|Local|
 | [SQS, Lambda, DynamoDB](./dotnet-test-samples/sqs-lambda)|.NET|
 | [API Gateway, Lambda, DynamoDB](./java-test-samples/apigw-lambda-ddb)|Java|
 | [AppSync, DynamoDB](./java-test-samples/java-appsync-sam)|Java|
@@ -57,6 +62,8 @@ Event-driven architectures (EDA) are an architecture style that uses events and
 |[Schemas and Contracts](./typescript-test-samples/schema-and-contract-testing)|TypeScript|Event driven architectures decouple producers and consumers at the infrastructure layer, but these resources may still be coupled at the application layer by the event contract. Learn how to test for breaking changes in the contract.|
 |[S3, Lambda, DynamoDB](./dotnet-test-samples/async-lambda-dynamodb)|.NET|This example shows how to test async system by using DynamoDB during to store incoming asynchronous events during testing|
 |[S3, Lambda, SQS](./dotnet-test-samples/async-lambda-sqs)|.NET|An example to how to test asynchronous workflow by long polling the queue that resulting messages are sent to.|
+|[Lambda, SAM, HelloWorld](./local-test-samples/lambda-sam-helloworld)|Local| Local Lambda HelloWorld implementation |
+|[Lambda, SAM, Layers](./local-test-samples/lambda-sam-layers)|Local| Local Lambda emulator  Layers implementation |
 
 ## Architectural patterns
 |Pattern|Services used|Language|Description|
@@ -67,13 +74,22 @@ Event-driven architectures (EDA) are an architecture style that uses events and
 |System Under Test|Language|Description|
 |---|---|---|
 | [Step Functions](./java-test-samples/step-functions-local) [External] |Java|This project shows a technique for testing an AWS Step Functions workflow in a local desktop environment.|
+| [Step Functions, HelloWorld](./local-test-samples/stepfunctions-helloworld) |Local| Local Hello World Step Functions implementation |
+| [Step Functions, Lambda](./local-test-samples/stepfunctions-lambda) |Local| Local Lambda execution integrated with local Hello World Step Functions implementation |
+| [Step Functions, MOCK](./local-test-samples/stepfunctions-mock) |Local| Mocking answers from local Hello World Step Functions implementation |
 
 ## Data Processing
 | System Under Test|Language|Description|
 |---|---|---|
 |[Kinesis Data Stream, Lambda](./typescript-test-samples/kinesis-lambda-dynamodb)|TypeScript|This project shows a technique for testing a streaming data processing system.|
 |[Kinesis Data Stream, Lambda, DynamoDB](./dotnet-test-samples/kinesis-lambda-dynamodb)|.NET|This pattern creates an AWS Lambda function that consumes messages from an Amazon Kinesis Data Streams and dumps them to Amazon DynamoDB using SAM and .NET 6.|
 
+## Database
+| System Under Test|Language|Description|
+| [DynamoDB, aws cli](./local-test-samples/dynamodb-crud-cli)|Local| DynamoDB CRUD operations using local docker image and aws cli |
+| [DynamoDB, Lambda](./local-test-samples/dynamodb-crud-lambda)|Local| DynamoDB CRUD operations using docker image and local lambda local emulator |
+| [DynamoDB, StepFunctions](./local-test-samples/dynamodb-crud-stepfunctions)|Local| DynamoDB CRUD operations using docker image and step functions local emulator |
+
 ## AWS Partner Patterns
 | Partner |System Under Test|Language|Description|
 |---|---|---|---|

local-test-samples/apigateway-crud-lambda-dynamodb/README.md

@@ -0,0 +1,159 @@
+[![python: 3.9](https://img.shields.io/badge/Python-3.9-green)](https://img.shields.io/badge/Python-3.9-green)
+[![AWS: DynamoDB](https://img.shields.io/badge/AWS-DynamoDB-blueviolet)](https://img.shields.io/badge/AWS-DynamoDB-blueviolet)
+[![AWS: Lambda](https://img.shields.io/badge/AWS-Lambda-orange)](https://img.shields.io/badge/AWS-Lambda-orange)
+[![AWS: API Gateway](https://img.shields.io/badge/AWS-API%20Gateway-blue)](https://img.shields.io/badge/AWS-API%20Gateway-blue)
+[![test: local](https://img.shields.io/badge/Test-Local-red)](https://img.shields.io/badge/Test-Local-red)
+
+# Local: Amazon Api Gateway, AWS Lambda, Amazon DynamoDB CRUD Operations
+
+## Introduction
+This project demonstrates how to perform local testing of AWS serverless applications using SAM CLI and Docker. It implements a complete CRUD operation cycle through API Gateway, with Lambda functions processing the requests and DynamoDB storing the data.
+
+---
+
+## Contents
+- [Local: Amazon Api Gateway, AWS Lambda, Amazon DynamoDB CRUD Operations](#local-amazon-api-gateway-aws-lambda-amazon-dynamodb-crud-operations)
+  - [Introduction](#introduction)
+  - [Contents](#contents)
+  - [Project Structure](#project-structure)
+  - [Architecture Overview](#architecture-overview)
+  - [Local Setup Requirements](#local-setup-requirements)
+  - [Running the Tests](#running-the-tests)
+  - [API Endpoints](#api-endpoints)
+  - [Test Sequence](#test-sequence)
+  - [Additional Resources](#additional-resources)
+
+---
+
+## Project Structure
+```
+├── apigateway-crud-lambda-dynamodb     _# folder containing necessary code and template for CRUD operations with API Gateway, Lambda Functions and DynamoDB_
+│   ├── events                          _# folder containing json files for API Gateway CRUD input events_
+│   ├── img/apigateway-crud-lambda-dynamodb.png _# Architecture diagram_
+│   ├── lambda_crud_src                 _# folder containing code for different CRUD Lambda functions_
+│   ├── README.md                       _# instructions file_
+│   └── template.yaml                   _# sam yaml template file for necessary components test_
+
+```
+
+[Top](#contents)
+
+---
+
+## Architecture Overview
+
+<p align="center">
+  <img src="img/apigateway-crud-lambda-dynamodb.png" alt="API Gateway - CRUD + Lambda + DynamoDB" width="300"/>
+</p>
+
+The application consists of:
+- API Gateway (emulated locally by SAM)
+- Lambda functions (Python 3.9) (emulated locally by SAM)
+- DynamoDB table (running locally via Docker)
+
+[Top](#contents)
+
+---
+
+## Local Setup Requirements
+- Docker (SAM emulation)
+- AWS SAM CLI
+- Python 3.9
+- curl (for testing)
+
+[Top](#contents)
+
+---
+
+## Running the Tests
+
+1. Start DynamoDB locally:
+```sh
+docker run --rm -d --network host -p 8000:8000 amazon/dynamodb-local
+```
+
+2. Start the API Gateway emulator:
+```sh
+sam local start-api --docker-network host &
+```
+
+3. Initialize the DynamoDB table (though Api Gateway -> Lambda crud init function):
+```sh
+curl -X GET http://127.0.0.1:3000/init
+```
+
+[Top](#contents)
+
+---
+
+## API Endpoints
+
+| Endpoint | Method | Description |
+|----------|--------|-------------|
+| /init | GET | Creates DynamoDB CRUDLocalTable table |
+| /create | POST | Creates new item |
+| /read | GET | Retrieves an item |
+| /update | POST | Updates existing item |
+| /delete | GET | Deletes an item |
+
+[Top](#contents)
+
+---
+
+## Test Sequence
+
+1. Create initial item:
+```sh
+curl -X POST http://127.0.0.1:3000/create \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123", "name": "Batman"}'
+```
+
+2. Read item:
+```sh
+curl -X GET http://127.0.0.1:3000/read \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123"}'
+```
+
+3. Update initial item:
+```sh
+curl -X POST http://127.0.0.1:3000/update \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123", "name": "Robin"}'
+```
+
+4. Check updated item:
+```sh
+curl -X GET http://127.0.0.1:3000/read \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123"}'
+```
+
+5. Delete item:
+```sh
+curl -X GET http://127.0.0.1:3000/delete \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123"}'
+```
+
+6. Checking item does not exist:
+```sh
+curl -X GET http://127.0.0.1:3000/read \
+  -H 'Content-Type: application/json' \
+  -d '{"Id": "123"}'
+```
+
+[Top](#contents)
+
+---
+
+## Additional Resources
+- [API Gateway Docs SAM] [AWS Serverless Application Model - Developer Guide - Locally run API Gateway with AWS SAM](https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-cli-using-start-api.html)
+- [Lambda Docs SAM] [AWS Serverless Application Model - Developer Guide - Locally invoke Lambda functions with AWS SAM](https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-cli-using-invoke.html)
+- [Amazon DynamoDB Developer Guide] [Amazon DynamoDB - Developer Guide - Deploying DynamoDB locally on your computer](https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/DynamoDBLocal.DownloadingAndRunning.html)
+
+
+[Top](#contents)
+
+---

local-test-samples/apigateway-crud-lambda-dynamodb/events/lambda-create-event.json

@@ -0,0 +1,3 @@
+{
+  "body": "{\"Id\": \"123\", \"name\": \"Batman\"}"
+}

local-test-samples/apigateway-crud-lambda-dynamodb/events/lambda-delete-event.json

@@ -0,0 +1,3 @@
+{
+  "Id": "123"
+}

local-test-samples/apigateway-crud-lambda-dynamodb/events/lambda-init-event.json

@@ -0,0 +1,5 @@
+{
+  "key1": "value1",
+  "key2": "value2",
+  "key3": "value3"
+}

local-test-samples/apigateway-crud-lambda-dynamodb/events/lambda-read-event.json

@@ -0,0 +1,3 @@
+{
+  "Id": "123"
+}

local-test-samples/apigateway-crud-lambda-dynamodb/events/lambda-update-event.json

@@ -0,0 +1,3 @@
+{
+  "body": "{\"Id\": \"123\", \"name\": \"Robin\"}"
+}

local-test-samples/apigateway-crud-lambda-dynamodb/img/apigateway-crud-lambda-dynamodb.png

@@ -0,0 +1,22 @@
+import os
+import json
+import boto3
+def lambda_handler(event, context):
+    # Checking if running locally
+    if os.environ.get('AWS_SAM_LOCAL'):
+        # Use local DynamoDB endpoint
+        dynamodb = boto3.resource('dynamodb', endpoint_url='http://172.17.0.1:8000')
+    else:
+        # Use the default DynamoDB endpoint (AWS)
+        dynamodb = boto3.resource('dynamodb')
+
+    # Adding an item to DynamoDB
+    item = json.loads(event['body'])
+
+    table = dynamodb.Table(os.environ['DYNAMODB_TABLE'])
+    response = table.put_item(Item=item)
+
+    return {
+        'statusCode': 200,
+        'body': json.dumps({'message': 'Item added', 'response': response})
+    }

local-test-samples/apigateway-crud-lambda-dynamodb/lambda_crud_src/lambda_crud_create_src/app.py

@@ -0,0 +1,27 @@
+import os
+import json
+import boto3
+
+def lambda_handler(event, context):
+    # Checking if running locally
+    if os.environ.get('AWS_SAM_LOCAL'):
+        # Use local DynamoDB endpoint
+        dynamodb = boto3.resource('dynamodb', endpoint_url='http://172.17.0.1:8000')
+    else:
+        # Use the default DynamoDB endpoint (AWS)
+        dynamodb = boto3.resource('dynamodb')
+
+    # Parse the JSON body
+    body = json.loads(event['body'])
+
+    # Access the Id element
+    item_id = body['Id']
+
+    # Deleting item on DynamoDB
+    table = dynamodb.Table(os.environ['DYNAMODB_TABLE'])
+    response = table.delete_item(Key={'Id': item_id})
+
+    return {
+        'statusCode': 200,
+        'body': json.dumps({'message': 'Item deleted', 'response': response})
+    }