DynamoDB와 Amazon EventBridge 통합

DynamoDB 개발자 안내서의 스트림 활성화 섹션에 있는 단계를 따라 소스 테이블에서 DynamoDB Streams를 활성화합니다. 소스 테이블에서 DynamoDB Streams가 이미 활성화되어 있는 경우, 현재 소비자가 2명 미만인지 확인하세요. 소비 대상은 Lambda 함수, DynamoDB 전역 테이블, Amazon OpenSearch Service와의 Amazon DynamoDB 제로 ETL 통합 또는 DynamoDB Streams Kinesis 어댑터 등을 통해 스트림에서 직접 읽는 애플리케이션 등일 수 있습니다.

EventBridge 사용 설명서의 Amazon EventBridge 이벤트 버스 만들기 섹션에 있는 단계에 따라 EventBridge 이벤트 버스를 생성합니다.

EventBridge 사용 설명서의 Amazon EventBridge 파이프 만들기 섹션에 있는 단계에 따라 EventBridge 파이프를 생성합니다.

소스 DynamoDB 테이블에 예제 항목을 작성하여 이벤트를 트리거합니다. 이렇게 하면 EventBridge가 예제 항목에서 스키마를 유추할 수 있습니다. 이 스키마를 사용하여 라우팅 이벤트에 대한 규칙을 생성할 수 있습니다. 예를 들어, 속성 오버로드가 포함된 설계 패턴을 구현하는 경우 정렬 키 값에 따라 다른 규칙을 트리거해야 할 수 있습니다. DynamoDB에 항목을 쓰는 방법에 대한 자세한 내용은 DynamoDB 개발자 안내서의 항목 및 속성 작업 섹션에서 확인할 수 있습니다.

Lambda 개발자 안내서의 Python을 사용하여 Lambda 함수 빌드 섹션에 있는 단계에 따라 대상으로 사용할 예제 Python Lambda 함수를 생성합니다. 함수를 생성할 때 아래 예제 코드를 사용하여 통합을 시연할 수 있습니다. 간접 호출되면 CloudWatch Logs에서 볼 수 있는 이벤트와 함께 수신된 NewImage 및 OldImage가 출력됩니다.

import json

def lambda_handler(event, context):
    dynamodb = event.get('detail', {}).get('dynamodb', {})
    new_image = dynamodb.get('NewImage')
    old_image = dynamodb.get('OldImage')
    
    if new_image:
        print("NewImage:", json.dumps(new_image, indent=2))
    if old_image:
        print("OldImage:", json.dumps(old_image, indent=2))
    
    return {'statusCode': 200, 'body': json.dumps(event)}

Create a rule 섹션의 단계에 따라 이벤트에 반응하는 새 Lambda 함수로 이벤트를 라우팅하는 EventBridge 규칙을 생성합니다.

이제 EventBridge 사용 설명서의 이벤트 버스에서 스키마 검색 시작 또는 중지 섹션에 있는 단계에 따라 이벤트 버스에서 스키마 검색을 중지할 수 있습니다.

두 번째 예제 항목을 소스 DynamoDB 테이블에 작성하여 이벤트를 트리거합니다. 각 단계에서 이벤트가 성공적으로 처리되었는지 검증하세요.