pengantar

Ide

• menyimpan data dari formulir ke database;
• mengirim surat ke agen yang akan menjawab pertanyaan;
• mungkin menulis layanan lain di mana agen akan menandai pekerjaan yang dilakukan berdasarkan database yang sama (tidak termasuk dalam ruang lingkup artikel).

Arsitektur

• mesin di belakang, depan, gambar, dll.,
• mobil dengan pangkalan
• mesin dengan layanan email.

• AWS Lambda adalah komponen utama yang berisi kode / logika,
• S3 bertanggung jawab untuk menyimpan sumber daya statis dan skrip JS,
• CloudFront - untuk mekanisme caching dan dukungan multi-regional,
• SES - layanan email,
• DynamoDB - basis untuk menyimpan data dari formulir (dari siapa, pertanyaan apa, ke mana harus mengirim jawabannya),
• Gateway API - API HTTP untuk lambda kami,
• Route53 - diperlukan jika Anda ingin menambahkan nama domain yang indah.

• Kami bergerak menjauh dari mendukung mesin EC2, tidak ada debugging melalui ssh,
• Konfigurasi mudah: konfigurasikan pembatasan / caching / akses dalam satu klik,
• Mendukung kebijakan akses: membatasi hak dan memberikan akses,
• Log out / pemantauan di luar kotak,
• Bayar hanya untuk sumber daya yang digunakan / permintaan.

Demo

Latihan

• Akun AWS aktif
• aws-cli
• sam-cli
• Jdk 11
• Gradle

Perakitan proyek

1. Buat proyek dari templat

2. Mari kita berurusan dengan kecanduan

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. Kami menulis lambda

• Kami mengubah kelas templat permintaan dan respons untuk RequestHandler menjadi AwsProxyRequest dan 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. Kami menulis tes

5. Kami menulis templat sumber daya 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. Kami melanjutkan ke penyebaran

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. Periksa status CloudFormation

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

• ServerlessRestApi
• ServerlessRestApiDeployment
• ServerlessRestApiProdStage

8. Formulir HTML KontakUs

$("#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?");

• Buat ember S3 baru.
• Kami memuat file HTML ke dalam ember dengan memilih opsi untuk menjadikan file tersebut publik.
• Kami masuk ke ember tempat kami mengunggah file.
• Buka Properti, lalu aktifkan hosting situs web Static dan lihat Endpoint baru Anda yang tersedia untuk umum.

9. Pemeriksaan Kesehatan

Berhasil: Pesan 0102016f28b06243-ae897a1e-b805-406b-9987-019f21547682-000000 telah berhasil dikirim.

Meringkas

• Free Tier , , .
• 1-2 . /.
• , , .
• Serverless . , — . SAM AWS. AWS , , .
• Lambda , .
• Serverless , , . ELK/Promethes/Grafana .
• , API. API Key, IAM , .
• Yah, mungkin yang paling mendasar adalah Serverless. Tidak perlu memikirkan instance EC2 mana yang harus Anda bayar, cara mengkonfigurasi akses ke sana, cara mengkonfigurasi peringatan jika terjadi crash aplikasi, mengkonfigurasi penskalaan otomatis, dll.

• Mulai dingin. Terutama signifikan saat menggunakan kueri sinkron, dan bahasa seperti Java atau C #. Masalahnya cukup diselesaikan dengan pemanasan, tetapi lebih baik memikirkan solusi seperti itu di muka dan membandingkan biaya dan kemungkinan manfaatnya
• . 3GB , 2 , , - Fargate, , .
• API, , .
• / 1-2 Serverless, .
• Jika Anda sudah memiliki infrastruktur untuk mengembangkan layanan microser dan CI / CD di Coober, akan lagi menjadi masalah untuk berdebat (terutama untuk manajer) kebutuhan untuk mendukung proses CI / CD lainnya.
• Nah, di mana tanpa pengujian. Dan untuk menguji lambda untuk throughput cukup sulit, karena masih berbeda dari pengujian kinerja biasa, dan ada banyak faktor yang perlu dipertimbangkan.

PS

• Proyek GitHub
• Unduh AWS-CLI
• Unduh SAM-CLI
• Konfigurasi AWS-CLI
• Infrastruktur sebagai kode
• Pengalaman menggunakan Terraform
• Deskripsi sumber daya SAM
• Alias ​​Fungsi AWS Lambda
• Penempatan lambda tingkat lanjut
• Konfigurasi Sumber Daya SAM Api
• AWS IAM
• SES
• Read/Write capacity DynamoDB
• SAM/CloudFormation
• Parameters
• CloudFormation