Python Lambda 함수를 위한 계층 작업

다음 방법 중 하나를 선택하여 필요한 최상위 디렉터리(python/)에 pip 패키지를 설치합니다.

python 디렉터리의 내용을 압축합니다.

.zip 파일의 디렉터리 구조는 다음과 같아야 합니다.

python/              # Required top-level directory
└── requests/
└── boto3/
└── numpy/
└── (dependencies of the other packages)

계층에 필요한 최상위 디렉터리를 생성합니다.

mkdir python

python 디렉터리에서 Python 모듈을 생성합니다. 다음 예시 모듈은 주문에 필수 정보가 포함되어 있는지 확인하여 주문을 검증합니다.

import json

def validate_order(order_data):
    """Validates an order and returns formatted data."""
    required_fields = ['product_id', 'quantity']
    
    # Check required fields
    missing_fields = [field for field in required_fields if field not in order_data]
    if missing_fields:
        raise ValueError(f"Missing required fields: {', '.join(missing_fields)}")
    
    # Validate quantity
    quantity = order_data['quantity']
    if not isinstance(quantity, int) or quantity < 1:
        raise ValueError("Quantity must be a positive integer")
    
    # Format and return the validated data
    return {
        'product_id': str(order_data['product_id']),
        'quantity': quantity,
        'shipping_priority': order_data.get('priority', 'standard')
    }

def format_response(status_code, body):
    """Formats the API response."""
    return {
        'statusCode': status_code,
        'body': json.dumps(body)
    }

python 디렉터리의 내용을 압축합니다.

.zip 파일의 디렉터리 구조는 다음과 같아야 합니다.

python/     # Required top-level directory
└── validator.py

함수에서 Python 패키지와 마찬가지로 모듈을 가져와서 사용합니다. 예시:

from validator import validate_order, format_response
import json

def lambda_handler(event, context):
    try:
        # Parse the order data from the event body
        order_data = json.loads(event.get('body', '{}'))
        
        # Validate and format the order
        validated_order = validate_order(order_data)
        
        return format_response(200, {
            'message': 'Order validated successfully',
            'order': validated_order
        })
    except ValueError as e:
        return format_response(400, {
            'error': str(e)
        })
    except Exception as e:
        return format_response(500, {
            'error': 'Internal server error'
        })

다음 테스트 이벤트를 사용하여 함수를 간접적으로 호출할 수 있습니다.

{
    "body": "{\"product_id\": \"ABC123\", \"quantity\": 2, \"priority\": \"express\"}"
}

예상 응답:

{
  "statusCode": 200,
  "body": "{\"message\": \"Order validated successfully\", \"order\": {\"product_id\": \"ABC123\", \"quantity\": 2, \"shipping_priority\": \"express\"}}"
}