परिचय

विचार

• डेटाबेस से डेटा को फॉर्म में सेव करें;
• एक एजेंट को एक पत्र भेजें जो सवाल का जवाब देगा;
• शायद एक और सेवा लिखें जहां एजेंट उसी डेटाबेस के आधार पर किए गए काम को चिह्नित करेगा (लेख के दायरे में शामिल नहीं है)।

आर्किटेक्चर

• मशीन के तहत वापस, सामने, चित्र, आदि
• आधार के साथ कार
• ईमेल सेवा के साथ मशीन।

• AWS लैम्ब्डा मुख्य घटक है जिसमें कोड / तर्क शामिल हैं,
• एस 3 स्थिर संसाधनों और जेएस लिपियों के भंडारण के लिए जिम्मेदार है,
• CloudFront - कैशिंग तंत्र और बहु-क्षेत्रीय समर्थन के लिए,
• SES - ईमेल सेवा,
• DynamoDB - फॉर्म से डेटा संग्रहीत करने के लिए आधार (किससे, क्या सवाल, जवाब कहां भेजना है),
• गेटवे एपीआई - हमारे एपीआई के लिए HTTP एपीआई,
• यदि आप एक सुंदर डोमेन नाम जोड़ना चाहते हैं, तो रूट53 - की जरूरत है।

• हम EC2 मशीनों का समर्थन करने से दूर जा रहे हैं, ssh के माध्यम से डिबगिंग नहीं,
• आसान कॉन्फ़िगरेशन: थ्रॉटलिंग / कैशिंग / एक्सेस को एक क्लिक में कॉन्फ़िगर करें,
• पहुँच नीतियों का समर्थन करता है: अधिकारों को प्रतिबंधित करें और पहुँच प्रदान करें,
• बॉक्स से लॉगिंग / निगरानी करना,
• केवल उपयोग किए गए संसाधनों / अनुरोधों के लिए भुगतान करें।

डेमो

प्रशिक्षण

• सक्रिय AWS खाता
• एडब्ल्यूएस-CLI
• सैम-CLI
• Jdk 11
• Gradle

प्रोजेक्ट असेंबली

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. हम एक मेमना लिखते हैं

• हम 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. हम एसएएम संसाधनों का एक खाका लिखते हैं

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
• ServerlessRestApiDeployment
• ServerlessRestApiProdStage

8. HTML संपर्क फ़ॉर्म

$("#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 , .
• खैर, शायद सबसे बुनियादी बात सर्वर रहित है। इस बात पर विचार करने की आवश्यकता नहीं है कि ईसी 2 उदाहरण आपको किसके लिए भुगतान करने की आवश्यकता है, इसका उपयोग कैसे कॉन्फ़िगर करें, एप्लिकेशन क्रैश की स्थिति में अलर्ट कैसे कॉन्फ़िगर करें, ऑटो-स्केलिंग कॉन्फ़िगर करें आदि।

• ठंडी शुरुआत। विशेष रूप से महत्वपूर्ण जब तुल्यकालिक प्रश्नों का उपयोग करते हैं, और जावा या सी # जैसी भाषाएं। समस्या को गर्म करके हल किया जाता है, लेकिन पहले से इस तरह के समाधान के बारे में सोचना और लागत और संभावित लाभों की तुलना करना बेहतर है
• . 3GB , 2 , , - Fargate, , .
• API, , .
• / 1-2 Serverless, .
• यदि आपके पास पहले से ही Coober में microservices और CI / CD को विकसित करने के लिए बुनियादी ढांचा है, तो यह फिर से बहस करने के लिए समस्याग्रस्त होगा (विशेषकर प्रबंधकों के लिए) एक और CI / CD प्रक्रिया का समर्थन करने की आवश्यकता।
• खैर, बिना परीक्षण के कहां। और थ्रूपुट के लिए लैम्ब्डा का परीक्षण करना काफी मुश्किल है, क्योंकि यह अभी भी सामान्य छिड़काव परीक्षण से अलग है, और कई कारकों को ध्यान में रखा जाना चाहिए।

पुनश्च

• गिटहब परियोजना
• AWS-CLI डाउनलोड करें
• SAM-CLI डाउनलोड करें
• AWS-CLI कॉन्फ़िगरेशन
• कोड के रूप में अवसंरचना
• Terraform का उपयोग कर अनुभव
• एसएएम संसाधनों का विवरण
• AWS लाम्बा फंक्शन एलियासेस
• उन्नत लंबोदर की तैनाती
• एसएएम एपि संसाधन विन्यास
• AWS IAM
• SES
• Read/Write capacity DynamoDB
• SAM/CloudFormation
• Parameters
• CloudFormation