介绍

理念

• 将数据从表单保存到数据库；
• 寄信给将回答问题的代理商；
• 也许编写另一个服务，代理将在该服务上标记基于同一数据库完成的工作（不包括在本文范围内）。

建筑

• 机器背面，正面，图像等下方，
• 带底座车
• 机带有电子邮件服务。

• AWS Lambda是包含代码/逻辑的主要组件，
• S3负责存储静态资源和JS脚本，
• CloudFront-用于缓存机制和多区域支持，
• SES-电子邮件服务，
• DynamoDB-用于存储表单数据的基础（从谁那里，什么问题，在哪里发送答案），
• 网关API-用于我们的lambda的HTTP API，
• Route53-如果要添加漂亮的域名，则需要。

• 我们不再支持EC2机器，不再通过ssh进行调试，
• 轻松配置：一键配置限制/缓存/访问，
• 支持访问策略：限制权限并授予访问权限，
• 开箱即用地记录/监视，
• 只为已使用的资源/请求付费。

演示版

训练

• 有效的AWS账户
• aws-cli
• 桑克里
• 杰克11
• 摇篮

项目组装

1.从模板创建项目

2.让我们应对成瘾

dependencies {
    // AWS
    implementation group: 'com.amazonaws.serverless', name: 'aws-serverless-java-container-core', version: '1.4'
    implementation group: 'com.amazonaws', name: 'aws-lambda-java-core', version: '1.2.0'
    implementation group: 'com.amazonaws', name: 'aws-java-sdk-ses', version: '1.11.670'
    implementation group: 'com.amazonaws', name: 'aws-java-sdk-dynamodb', version: '1.11.670'
    implementation group: 'com.amazonaws', name: 'aws-lambda-java-log4j2', version: '1.1.0'

    // Utils
    implementation group: 'com.fasterxml.jackson.core', name: 'jackson-core', version: '2.10.0'
    implementation group: 'commons-io', name: 'commons-io', version: '2.6'

    // Test
    testImplementation group: 'org.mockito', name: 'mockito-core', version: '3.1.0'
    testImplementation group: 'org.powermock', name: 'powermock-api-mockito2', version: '2.0.4'
    testImplementation group: 'org.powermock', name: 'powermock-module-junit4', version: '2.0.4'
    testImplementation group: 'junit', name: 'junit', version: '4.12'
}

3.我们写一个lambda

• 我们将RequestHandler的模板请求和响应类更改为AwsProxyRequest和ContactUsProxyResponse。

  public class App implements RequestHandler<AwsProxyRequest, ContactUsProxyResponse>
  ...
  public ContactUsProxyResponse handleRequest(AwsProxyRequest request, Context context) 

  
  
• AwsClientFactory AWS SDK-.

  /**
   * Just an util class for an eager initialization of sdk clients.
   */
  public class AwsClientFactory {
  
      private static final Logger LOG = LogManager.getLogger(AwsClientFactory.class);
  
      private final AmazonSimpleEmailService sesClient;
      private final DynamoDB dynamoDB;
  
      /**
       * AWS regions should be env variables if you want to generalize the solution.
       */
      AwsClientFactory() {
          LOG.debug("AWS clients factory initialization.");
          sesClient = AmazonSimpleEmailServiceClient.builder().withRegion(Regions.EU_WEST_1).build();
          AmazonDynamoDB dynamoDBClient = AmazonDynamoDBClientBuilder.standard().withRegion(Regions.EU_WEST_1).build();
          dynamoDB = new DynamoDB(dynamoDBClient);
      }
  
      DynamoDB getDynamoDB() {
          return dynamoDB;
      }
  
      AmazonSimpleEmailService getSesClient() {
          return sesClient;
      }
  
  }
  

  
  
• ObjectMapper .

  
  private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
  private static final AwsClientFactory AWS_CLIENT_FACTORY = new AwsClientFactory();
  

  
  
• .

  
   private SendEmailResult sendEmail(ContactUsRequest contactUsRequest) {
          String emailTemplate = getEmailTemplate();
          String email = fillTemplate(emailTemplate, contactUsRequest);
  
          SendEmailRequest sendEmailRequest =
                  new SendEmailRequest(
                          System.getenv("SENDER_EMAIL"),
                          new Destination(List.of(System.getenv("RECIPIENT_EMAIL"))),
                          new Message()
                                  .withSubject(
                                          new Content()
                                                  .withCharset(UTF_8.name())
                                                  .withData(contactUsRequest.getSubject()))
                                  .withBody(new Body()
                                          .withHtml(new Content()
                                                  .withCharset(UTF_8.name())
                                                  .withData(email))));
          LOG.info("Email template is ready");
          return AWS_CLIENT_FACTORY.getSesClient().sendEmail(sendEmailRequest);
  }
  
  private String fillTemplate(String emailTemplate, ContactUsRequest contactUsRequest) {
          return String.format(
                  emailTemplate,
                  contactUsRequest.getUsername(),
                  contactUsRequest.getEmail(),
                  contactUsRequest.getPhone(),
                  contactUsRequest.getQuestion());
  }
  
  private String getEmailTemplate() {
          try {
              return IOUtils.toString(
                      Objects.requireNonNull(this.getClass().getClassLoader()
                                                 .getResourceAsStream("email_template.html")),
                      UTF_8);
          } catch (IOException e) {
              throw new RuntimeException("Loading an email template failed.", e);
          }
  }
  
  private void addEmailDetailsToDb(ContactUsRequest contactUsRequest, SendEmailResult sendEmailResult) {
          AWS_CLIENT_FACTORY.getDynamoDB().getTable("ContactUsTable")
                            .putItem(new Item()
                                    .withPrimaryKey("Id", sendEmailResult.getMessageId())
                                    .withString("Subject", contactUsRequest.getSubject())
                                    .withString("Username", contactUsRequest.getUsername())
                                    .withString("Phone", contactUsRequest.getPhone())
                                    .withString("Email", contactUsRequest.getEmail())
                                    .withString("Question", contactUsRequest.getQuestion()));
  }
  

  
  
• .

  
  private ContactUsProxyResponse buildResponse(int statusCode, String body) {
          ContactUsProxyResponse awsProxyResponse =
                  new ContactUsProxyResponse();
          awsProxyResponse.setStatusCode(statusCode);
          awsProxyResponse.setBody(getBodyAsString(body));
          awsProxyResponse.addHeader(CONTENT_TYPE, ContentType.APPLICATION_JSON.toString());
          awsProxyResponse.addHeader("Access-Control-Allow-Origin", "*");
          return awsProxyResponse;
  }
  
   private String getBodyAsString(String body) {
          try {
              return OBJECT_MAPPER.writeValueAsString(new ContactUsResponseBody(body));
          } catch (JsonProcessingException e) {
              throw new RuntimeException("Writing ContactUsResponseBody as string failed.", e);
          }
  }
  

  
  
• . «// WARMING UP».

  
  if (Optional.ofNullable(request.getMultiValueHeaders()).map(headers -> headers.containsKey("X-WARM-UP")).orElse(FALSE)) {
              LOG.info("Lambda was warmed up");
              return buildResponse(201, "Lambda was warmed up. V1");
  }
  

  
  
• handleRequest()

  
  @Override
  public ContactUsProxyResponse handleRequest(AwsProxyRequest request, Context context) {
          LOG.info("Request was received");
          LOG.debug(getAsPrettyString(request));
  
          if (Optional.ofNullable(request.getMultiValueHeaders()).map(headers -> headers.containsKey("X-WARM-UP")).orElse(FALSE)) {
              LOG.info("Lambda was warmed up");
              return buildResponse(201, "Lambda was warmed up. V1");
          }
  
          ContactUsRequest contactUsRequest = getContactUsRequest(request);
  
          SendEmailResult sendEmailResult = sendEmail(contactUsRequest);
          LOG.info("Email was sent");
  
          addEmailDetailsToDb(contactUsRequest, sendEmailResult);
          LOG.info("DB is updated");
  
          return buildResponse(200,
                  String.format("Message %s has been sent successfully.", sendEmailResult.getMessageId()));
  }
  

  
  

LambdaLogger logger = context.getLogger();

4.我们编写测试

5.我们编写了SAM资源模板

CodeUri: contact-us-function
Handler: com.gralll.sam.App::handleRequest
Runtime: java8
MemorySize: 256

AutoPublishAlias: live
DeploymentPreference:
  Type: Canary10Percent10Minutes

Events:
  ContactUs:
    Type: Api
    Properties:
      Path: /contact
      Method: post

Policies:
  - AWSLambdaExecute
  - Version: '2012-10-17'
    Statement:
      - Effect: Allow
        Action:
          - ses:SendEmail
          - ses:SendRawEmail
        Resource: 'arn:aws:ses:eu-west-1:548476639829:identity/aleksandrgruzdev11@gmail.com'
      - Effect: Allow
        Action:
          - dynamodb:List*
        Resource: '*'
      - Effect: Allow
        Action:
          - dynamodb:Get*
          - dynamodb:PutItem
          - dynamodb:DescribeTable
        Resource: 'arn:aws:dynamodb:*:*:table/ContactUsTable'

ContactUsTable:
  Type: AWS::Serverless::SimpleTable
  Properties:
    PrimaryKey:
      Name: Id
      Type: String
    TableName: ContactUsTable
    ProvisionedThroughput:
      ReadCapacityUnits: 2
      WriteCapacityUnits: 2

Globals:
  Function:
    Timeout: 15
  Api:
    Cors:
      AllowOrigin: "'*'"
      AllowHeaders: "'Content-Type,X-WARM-UP,X-Amz-Date,Authorization,X-Api-Key'"

Outputs:
  ContactUsApi:
    Description: "API Gateway endpoint URL for Prod stage for ContactUs function"
    Value: !Sub "https://${ServerlessRestApi}.execute-api.${AWS::Region}.amazonaws.com/Prod/contact/"
  ContactUsFunction:
    Description: "ContactUs Lambda Function ARN"
    Value: !GetAtt ContactUsFunction.Arn
  ContactUsFunctionIamRole:
    Description: "Implicit IAM Role created for ContactUs function"
    Value: !GetAtt ContactUsFunctionRole.Arn

6.我们继续进行部署

F:\aws\projects\contact-us-sam-app>sam build
Building resource 'ContactUsFunction'
Running JavaGradleWorkflow:GradleBuild
Running JavaGradleWorkflow:CopyArtifacts

Build Succeeded

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

Commands you can use next
=========================
[*] Invoke Function: sam local invoke
[*] Deploy: sam deploy –guided

aws s3 mb s3://bucket-name

sam package --output-template-file packaged.yaml --s3-bucket <YOUR_BACKET>

F:\aws\projects\contact-us-sam-app>sam package --output-template-file packaged.yaml --s3-bucket contact-us-sam-app
Uploading to ea0c122c06a50d9676fbf9000a80a3bf  9212768 / 9212768.0  (100.00%)

Successfully packaged artifacts and wrote output template to file packaged.yaml.
Execute the following command to deploy the packaged template
sam deploy --template-file F:\aws\projects\contact-us-sam-app\packaged.yaml --stack-name <YOUR STACK NAME>

sam deploy --template-file packaged.yaml --region eu-west-1 --capabilities CAPABILITY_IAM --stack-name contact-us-sam-app

7.检查CloudFormation的状态

Successfully created/updated stack - contact-us-sam-app in eu-west-1

• ServerlessRestApi
• ServerlessRestApi部署
• ServerlessRestApiProdStage

8. HTML ContactUs表单

$("#url-input").val("https://4ykskscuq0.execute-api.eu-west-1.amazonaws.com/Prod/contact");
$("#name-input").val("Mike");
$("#email-input").val("Mike@somemail.com");
$("#phone-input").val("+79999999999");
$("#description-input").val("How much does it cost?");

• 创建一个新的S3存储桶。
• 通过选择将文件公开的选项，我们将HTML文件加载到存储桶中。
• 我们进入上载文件的存储桶。
• 转到“属性”，然后打开“静态”网站托管，然后查看新的公共可用端点。

9.健康检查

成功：消息0102016f28b06243-ae897a1e-b805-406b-9987-019f21547682-000000已成功发送。

总结

• Free Tier , , .
• 1-2 . /.
• , , .
• Serverless . , — . SAM AWS. AWS , , .
• Lambda , .
• Serverless , , . ELK/Promethes/Grafana .
• , API. API Key, IAM , .
• 好吧，最基本的东西可能是无服务器。无需考虑需要为哪个EC2实例付费，如何配置对其的访问权限，在应用程序崩溃时如何配置警报，配置自动缩放等。

• 冷启动。在使用同步查询以及Java或C＃等语言时特别重要。通过预热可以适当地解决此问题，但最好事先考虑一下这种解决方案，然后比较成本和可能的收益
• . 3GB , 2 , , - Fargate, , .
• API, , .
• / 1-2 Serverless, .
• 如果您已经拥有在Coober中开发微服务和CI / CD的基础结构，那么（特别是对于管理人员）争辩是否需要支持另一个CI / CD流程将再次成为问题。
• 好吧，这里没有测试。而且，测试lambda的吞吐量非常困难，因为它仍然与通常的性能测试不同，并且必须考虑许多因素。

聚苯乙烯

• GitHub项目
• 下载AWS-CLI
• 下载SAM-CLI
• AWS-CLI配置
• 基础架构即代码
• 使用Terraform的经验
• SAM资源的描述
• AWS Lambda函数别名
• 高级Lambda部署
• SAM Api资源配置
• AWS IAM
• SES
• Read/Write capacity DynamoDB
• SAM/CloudFormation
• Parameters
• CloudFormation