拖放式开发无服务器应用程序：使用 Amazon 应用程序编译器 (Application Composer) 和 Amazon 无服务器应用程序模型 (SAM)

Transform: AWS::Serverless-2016-10-31
Resources:
 CustomerFunctionList:
 Type: AWS::Serverless::Function
 Properties:
 Description: !Sub
 - Stack ${AWS::StackName} Function ${ResourceName}
 - ResourceName: CustomerFunctionList
 CodeUri: src/ListCustomer
 Handler: index.handler
 Runtime: nodejs18.x
 MemorySize: 3008
 Timeout: 30
 Tracing: Active
 Events:
 Api23GET:
 Type: Api
 Properties:
 Path: /
 Method: GET
 RestApiId: !Ref Api23
 Environment:
 Variables:
 TABLE_NAME: !Ref CustomerTable
 TABLE_ARN: !GetAtt CustomerTable.Arn
 Policies:
 - DynamoDBCrudPolicy:
 TableName: !Ref CustomerTable
 CustomerFunctionListLogGroup:
 Type: AWS::Logs::LogGroup
 DeletionPolicy: Retain
 Properties:
 LogGroupName: !Sub /aws/lambda/${CustomerFunctionList}
 CustomerFunctionCreate:
 Type: AWS::Serverless::Function
 Properties:
 Description: !Sub
 - Stack ${AWS::StackName} Function ${ResourceName}
 - ResourceName: CustomerFunctionCreate
 CodeUri: src/CreateCustomer
 Handler: index.handler
 Runtime: nodejs18.x
 MemorySize: 3008
 Timeout: 30
 Tracing: Active
 Environment:
 Variables:
 TABLE_NAME: '!Ref CustomerTable'
 TABLE_ARN: '!GetAtt CustomerTable.Arn'
 TABLE_NAME_2: !Ref CustomerTable
 TABLE_ARN_2: !GetAtt CustomerTable.Arn
 Events:
 Api23POST:
 Type: Api
 Properties:
 Path: /
 Method: POST
 RestApiId: !Ref Api23
 Policies:
 - DynamoDBCrudPolicy:
 TableName: !Ref CustomerTable
 CustomerFunctionCreateLogGroup:
 Type: AWS::Logs::LogGroup
 DeletionPolicy: Retain
 Properties:
 LogGroupName: !Sub /aws/lambda/${CustomerFunctionCreate}
 CustomerTable:
 Type: AWS::DynamoDB::Table
 Properties:
 AttributeDefinitions:
 - AttributeName: id
 AttributeType: S
 BillingMode: PAY_PER_REQUEST
 KeySchema:
 - AttributeName: id
 KeyType: HASH
 StreamSpecification:
 StreamViewType: NEW_AND_OLD_IMAGES
 Api:
 Type: AWS::Serverless::Api
 Properties:
 Name: !Sub
 - ${ResourceName} From Stack ${AWS::StackName}
 - ResourceName: Api23
 StageName: Prod
 DefinitionBody:
 openapi: '3.0'
 info: {}
 paths:
 /:
 get:
 x-amazon-apigateway-integration:
 httpMethod: POST
 type: aws_proxy
 uri: !Sub arn:${AWS::Partition}:apigateway:${AWS::Region}:lambda:path/2015-03-31/functions/${CustomerFunctionList.Arn}/invocations
 responses: {}
 post:
 x-amazon-apigateway-integration:
 httpMethod: POST
 type: aws_proxy
 uri: !Sub arn:${AWS::Partition}:apigateway:${AWS::Region}:lambda:path/2015-03-31/functions/${CustomerFunctionCreate.Arn}/invocations
 responses: {}
 EndpointConfiguration: REGIONAL
 TracingEnabled: true
Metadata:
 AWS::Composer::Groups:
 Group:
 Label: CustomerFunctionsGroup
 Members:
 - CustomerFunctionList
 - CustomerFunctionCreate
Outputs:
 EndpointUrl:
 Description: HTTP REST endpoint URL
 Value: !Sub https://${Api23}.execute-api.${AWS::Region}.amazonaws.com/Prod

Outputs:
 EndpointUrl:
 Description: HTTP REST endpoint URL
 Value: !Sub https://${Api}.execute-api.${AWS::Region}.amazonaws.com/Prod

const { DynamoDBClient } = require("@aws-sdk/client-dynamodb");
const { DynamoDBDocumentClient, PutCommand } = require("@aws-sdk/lib-dynamodb");

const client = new DynamoDBClient({});
const ddbClient = DynamoDBDocumentClient.from(client);

exports.handler = async event => {
 try {
 console.log(JSON.stringify(event, undefined, 2));
 const requestBody = JSON.parse(event.body);

 const customer = {
 id: Date.now().toString(), // Use a timestamp as the ID
 ...requestBody,
 };

 console.log(`Adding customer with ID '${customer.id}' to table '${process.env.TABLE_NAME}' with attributes: ${JSON.stringify(customer, null, 2)}`);

 const params = {
 TableName: process.env.TABLE_NAME,
 Item: customer,
 };

 // Add data to DynamoDB table
 await ddbClient.send(new PutCommand(params));
 
 console.log(`Successfully saved customer '${customer.id}'`);
 
 return {
 statusCode: 201,
 body: JSON.stringify(customer),
 };
 } catch (err) {
 console.error(err);

 return {
 statusCode: 500,
 body: 'Internal Server Error',
 };
 }
};

{
 "name": "function",
 "version": "1.0.0",
 "devDependencies": {
 "@aws-sdk/lib-dynamodb": "^3.214.0"
 }
}

const { DynamoDBClient, ScanCommand } = require("@aws-sdk/client-dynamodb");

const client = new DynamoDBClient({});

exports.handler = async event => {
 try {
 // Log the event argument for debugging and for use in local development.
 console.log(JSON.stringify(event, undefined, 2));

 console.log(`Listing customers from table '${process.env.TABLE_NAME}'`);

 let ids = [];

 // Loop over all customers. If there are more customers after a request,
 // the response LastEvaluatedKey will have a non-null value that we can
 // pass in the next request to continue fetching more customers.
 let 
 lastEvaluatedKey;
 do {
 const command = new ScanCommand({
 TableName: process.env.TABLE_NAME,
 ProjectionExpression: "id",
 ExclusiveStartKey: lastEvaluatedKey
 });

 const response = await client.send(command);

 const additionalIds = response.Items.map(customer => customer.id);

 ids = ids.concat(additionalIds);

 lastEvaluatedKey = response.LastEvaluatedKey;
 } while (lastEvaluatedKey);

 console.log(`Successfully scanned for list of IDs: ${JSON.stringify(ids, null, 2)}`);

 return {
 statusCode: 200,
 body: JSON.stringify({
 ids
 })
 };
 } catch (err) {
 console.error(`Failed to list customers: ${err.message} (${err.constructor.name})`);

 return {
 statusCode: 500,
 body: "Internal Service Error"
 };
 }
};

{
 "name": "function",
 "version": "1.0.0",
 "devDependencies": {
 "@aws-sdk/lib-dynamodb": "^3.214.0"
 }
}

npm install aws-sdk

sam build

➜ buildon-sam-app sam build
Building codeuri: ../buildon-sam-app/src/ListCustomer runtime: nodejs18.x metadata: {} architecture: x86_64 functions: CustomerFunctionList
Running NodejsNpmBuilder:NpmPack
Running NodejsNpmBuilder:CopyNpmrcAndLockfile
Running NodejsNpmBuilder:CopySource
Running NodejsNpmBuilder:NpmInstall
Running NodejsNpmBuilder:CleanUpNpmrc
Running NodejsNpmBuilder:LockfileCleanUp
Building codeuri: ../buildon-sam-app/src/CreateCustomer runtime: nodejs18.x metadata: {} architecture: x86_64 functions: CustomerFunctionCreate
Running NodejsNpmBuilder:NpmPack
Running NodejsNpmBuilder:CopyNpmrcAndLockfile
Running NodejsNpmBuilder:CopySource
Running NodejsNpmBuilder:NpmInstall
Running NodejsNpmBuilder:CleanUpNpmrc
Running NodejsNpmBuilder:LockfileCleanUp

Build Succeeded

Built Artifacts: .aws-sam/build
Built Template : .aws-sam/build/template.yaml

Commands you can use next
=========================
[*] Validate SAM template: sam validate
[*] Invoke Function: sam local invoke
[*] Test Function in the Cloud: sam sync --stack-name {{stack-name}} --watch
[*] Deploy: sam deploy --guided

sam deploy --guided

...
CREATE_COMPLETE AWS::CloudFormation::Stack buildon-sam-app - 
------------------------------------------------------------------------
CloudFormation outputs from deployed stack
Outputs 
------------------------------------------------------------------------
Key EndpointUrl 
Description HTTP REST endpoint URL 
Value https://11yakge1yd.execute-api.<REGION>.amazonaws.com/Prod 
------------------------------------------------------------------------

Successfully created/updated stack - buildon-sam-app in<REGION>

version = 0.1
[default]
[default.deploy]
[default.deploy.parameters]
stack_name = "buildon-sam-app"
s3_bucket = "aws-sam-cli-managed-default-samclisourcebucket-<randomletters>"
s3_prefix = "buildon-sam-app"
region = "REGION"
confirm_changeset = true
capabilities = "CAPABILITY_IAM"
image_repositories = []

curl -X POST \ 
 https://<API_ENDPOINT> \ 
 -H 'Content-Type: application/json' \
 -d '{
 "name": "John Doe",
 "email": "johndoe@example.com"
 }'

{"id":"1680294275167","name":"John Doe","email":"johndoe@example.com"}% 

curl -X GET https://<API_ENDPOINT>

{"ids":[{"S":"1680294275167"}]}% 

git clone https://github.com/aws-samples/fresh-tracks.git
cd fresh-tracks/backend/FreshTracks/

sam delete --stack-name STACK_NAME

aws cloudformation list-stacks --query "StackSummaries[?contains(StackName,'STACK_NAME')].StackStatus"