Tạo hàm delete_order Lambda

Trong bước này, chúng ta sẽ tạo một hàm delete_order Lambda mới bằng cách sử dụng mẫu SAM.

Chuẩn bị

  1. Mở template.yaml trong mã nguồn bạn đã tải xuống trước đó.

    • Bình luận khối mã này.

      # BookApiDeployment:
#   Type: AWS::ApiGateway::Deployment
#   Properties:
#     RestApiId: !Ref BookApi
#   DependsOn:
#     - BookApiGet
#     - BookApiCreate
#     - BookApiDelete
#     - LoginApi
#     - RegisterApi
#     - ConfirmApi
#     - FcjCheckoutOrderApi
#     - FcjOrderManagementApi
#     - FcjHandleOrderApi

BookApiStage:
  Type: AWS::ApiGateway::Stage
  Properties:
    RestApiId: !Ref BookApi
    StageName: !Ref stage
#     DeploymentId: !Ref BookApiDeployment

      CreateDeleteOrderFunction

  2. Chạy các lệnh dưới đây.

    sam build
sam validate
sam deploy

    CreateDeleteOrderFunction

Tạo hàm FcjDeleteOrder

  1. Mở template.yaml trong mã nguồn bạn đã tải xuống trước đó.

    • Thêm các đoạn mã sau để tạo hàm FcjDeleteOrder.

      FcjDeleteOrderFunction:
  Type: AWS::Serverless::Function
  Properties:
    CodeUri: fcj-book-shop/delete_order
    Handler: delete_order.lambda_handler
    Runtime: python3.11
    FunctionName: delete_order
    Environment:
      Variables:
        SQS_QUEUE_URL: !Ref checkoutQueueUrl
    Architectures:
      - x86_64
    Policies:
      - Statement:
          - Sid: VisualEditor0
            Effect: Allow
            Action:
              - sqs:*
            Resource:
              - !Sub "arn:aws:sqs:${AWS::Region}:${AWS::AccountId}:${checkoutQueueName}"

FcjDeleteOrderApi:
  Type: AWS::ApiGateway::Method
  Properties:
    HttpMethod: DELETE
    RestApiId: !Ref BookApi
    ResourceId: !Ref FcjCheckoutOrderResource
    AuthorizationType: NONE
    Integration:
      Type: AWS_PROXY
      IntegrationHttpMethod: POST # For Lambda integrations, you must set the integration method to POST
      Uri: !Sub >-
        arn:aws:apigateway:${AWS::Region}:lambda:path/2015-03-31/functions/${FcjDeleteOrderFunction.Arn}/invocations
    MethodResponses:
      - StatusCode: "200"
        ResponseParameters:
          method.response.header.Access-Control-Allow-Origin: true
          method.response.header.Access-Control-Allow-Methods: true
          method.response.header.Access-Control-Allow-Headers: true

FcjDeleteOrderApiInvokePermission:
  Type: AWS::Lambda::Permission
  Properties:
    FunctionName: !Ref FcjDeleteOrderFunction
    Action: lambda:InvokeFunction
    Principal: apigateway.amazonaws.com
    SourceAccount: !Ref "AWS::AccountId"

      CreateDeleteOrderFunction

  2. Cấu trúc thư mục như sau.

    fcj-book-shop-sam-ws3
├── fcj-book-shop
│   ├── checkout_order
│   │   └── checkout_order.py
│   ├── order_management
│   │   └── order_management.py
│   ├── handle_order
│   │   └── handle_order.py
│   ├── delete_order
│   │   └── delete_order.py
│   ├── ...
│
└── template.yaml

    • Tạo thư mục delete_order trong thư mục fcj-book-shop-sam-ws6/fcj-book-shop/.

    • Tạo tệp delete_order.py và sao chép mã sau vào đó.

      import json
import boto3
import os

headers = {
    "Content-Type": "application/json",
    "Access-Control-Allow-Origin": "*",
    "Access-Control-Allow-Methods": "OPTIONS,POST,GET,DELETE",
    "Access-Control-Allow-Headers": "Content-Type,X-Amz-Date,Authorization,X-Api-Key,X-Amz-Security-Token"
}

sqs = boto3.client('sqs')

# Get value of the environment variables
queue_url = os.getenv('SQS_QUEUE_URL')


def lambda_handler(event, context):
    order = json.loads(event['body'])

    try:
        if 'receiptHandle' in order and order['receiptHandle']:
            sqs.delete_message(
                QueueUrl=queue_url,
                ReceiptHandle=order['receiptHandle']
            )

        else:
            raise Exception("No receiptHandle provided")

    except Exception as e:
        print(f"Error deleting order: {e}")
        raise Exception(f"Error deleting order: {e}")

    return {
        'statusCode': 200,
        'headers': headers,
        'body': json.dumps('Order deleted successfully')
    }

      CreateDeleteOrderFunction

  3. Bỏ bình luận khối mã này.

    BookApiDeployment:
  Type: AWS::ApiGateway::Deployment
  Properties:
    RestApiId: !Ref BookApi
  DependsOn:
    - BookApiGet
    - BookApiCreate
    - BookApiDelete
    - LoginApi
    - RegisterApi
    - ConfirmApi
    - FcjCheckoutOrderApi
    - FcjOrderManagementApi
    - FcjHandleOrderApi
    - FcjDeleteOrderApi

BookApiStage:
  Type: AWS::ApiGateway::Stage
  Properties:
    RestApiId: !Ref BookApi
    StageName: !Ref stage
    DeploymentId: !Ref BookApiDeployment

    CreateDeleteOrderFunction

  4. Chạy các lệnh dưới đây.

    sam build
sam validate
sam deploy

    CreateDeleteOrderFunction

Kiểm tra việc tạo

  1. Mở Amazon API Gateway console.

    • Nhấp vào fcj-serverless-api. CreateDeleteOrderFunction
    • Nhấp vào Resources trên menu bên trái.
    • Kiểm tra /order vừa được tạo. CreateDeleteOrderFunction

  2. Mở Amazon Lambda console.

    • Nhấp vào Functions trên menu bên trái.
    • Chọn hàm delete_order. CreateDeleteOrderFunction
    • Tại trang delete_order, kiểm tra hàm vừa được tạo. CreateDeleteOrderFunction