introduction

Idée

• enregistrer les données du formulaire dans la base de données;
• envoyer une lettre à un agent qui répondra à la question;
• peut-être écrire un autre service où l'agent marquera le travail effectué sur la base de la même base de données (non incluse dans la portée de l'article).

Architecture

• machine sous le dos, le devant, les images, etc.,
• voiture avec base
• machine avec service de messagerie.

• AWS Lambda est le composant principal qui contient du code / de la logique,
• S3 est responsable du stockage des ressources statiques et des scripts JS,
• CloudFront - pour les mécanismes de mise en cache et le support multi-régional,
• SES - service de messagerie,
• DynamoDB - la base de stockage des données du formulaire (de qui, quelle question, où envoyer la réponse),
• API de passerelle - API HTTP pour notre lambda,
• Route53 - nécessaire si vous souhaitez ajouter un beau nom de domaine.

• Nous nous éloignons de la prise en charge des machines EC2, pas de débogage via ssh,
• Configuration facile: configurez la limitation / la mise en cache / les accès en un seul clic,
• Prise en charge des politiques d'accès: restreindre les droits et donner accès,
• Journalisation / surveillance hors de la boîte,
• Payez uniquement pour les ressources / demandes utilisées.

Démo

Entraînement

• Compte AWS actif
• aws-cli
• sam-cli
• Jdk 11
• Gradle

Montage du projet

1. Créez un projet à partir d'un modèle

2. Traitons les dépendances

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. Nous écrivons un lambda

• Nous modifions les classes de demande et de réponse de modèle pour RequestHandler en AwsProxyRequest et 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. Nous écrivons des tests

5. Nous écrivons un modèle de ressources 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. Nous procédons au déploiement

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. Vérifiez l'état de CloudFormation

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

• ServerlessRestApi
• ServerlessRestApiDeployment
• ServerlessRestApiProdStage

8. Formulaire 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?");

• Créez un nouveau compartiment S3.
• Nous chargeons le fichier HTML dans le compartiment en choisissant l'option pour rendre le fichier public.
• Nous allons dans le seau où nous avons téléchargé le fichier.
• Accédez à Propriétés, puis activez l'hébergement de sites Web statiques et voyez votre nouveau point de terminaison accessible au public.

9. Bilan de santé

Réussi: le message 0102016f28b06243-ae897a1e-b805-406b-9987-019f21547682-000000 a été envoyé avec succès.

Résumer

• Free Tier , , .
• 1-2 . /.
• , , .
• Serverless . , — . SAM AWS. AWS , , .
• Lambda , .
• Serverless , , . ELK/Promethes/Grafana .
• , API. API Key, IAM , .
• Eh bien, la chose la plus fondamentale est probablement sans serveur. Il n'est pas nécessaire de penser à l'instance EC2 pour laquelle vous devez payer, comment configurer l'accès à celle-ci, comment configurer les alertes en cas de panne d'une application, configurer la mise à l'échelle automatique, etc.

• Démarrage à froid. Particulièrement important lors de l'utilisation de requêtes synchrones et de langages tels que Java ou C #. Le problème est modérément résolu par l'échauffement, mais il vaut mieux réfléchir à une telle solution à l'avance et comparer le coût et les avantages possibles
• . 3GB , 2 , , - Fargate, , .
• API, , .
• / 1-2 Serverless, .
• Si vous disposez déjà de l'infrastructure pour développer des microservices et CI / CD dans Coober, il sera à nouveau problématique de discuter (en particulier pour les gestionnaires) de la nécessité de prendre en charge un autre processus CI / CD.
• Eh bien, où sans tests. Et pour tester le lambda pour le débit est assez difficile, car il est toujours différent des tests de perfarmance habituels, et de nombreux facteurs doivent être pris en compte.

PS

• Projet GitHub
• Télécharger AWS-CLI
• Télécharger SAM-CLI
• Configuration AWS-CLI
• L'infrastructure comme code
• Expérience avec Terraform
• Description des ressources SAM
• Alias ​​de fonction AWS Lambda
• Déploiement lambda avancé
• Configuration des ressources SAM Api
• AWS IAM
• SES
• Read/Write capacity DynamoDB
• SAM/CloudFormation
• Parameters
• CloudFormation