기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
AWS Event Fork 파이프라인 사용 사례 예
다음 시나리오에서는 Event Fork 파이프라인을 사용하는 AWS 이벤트 기반 서버리스 전자 상거래 애플리케이션을 설명합니다. 에서 이 예제 전자 상거래 애플리케이션을
이 전자 상거래 애플리케이션은 API Gateway에서 RESTful API 호스팅하고 AWS Lambda 함수 에서 지원하는 를 통해 구매자의 주문을 받습니다CheckoutApiBackendFunction. 이 함수는 수신된 모든 주문을 라는 Amazon SNS 주제에 게시CheckoutEventsTopic하고, 이 주제는 다시 4개의 서로 다른 파이프라인으로 주문을 팬아웃합니다.
첫 번째 파이프라인은 전자 상거래 애플리케이션의 소유자가 설계 및 구현한 정규 체크아웃 처리 파이프라인입니다. 이 파이프라인에는 수신된 모든 주문을 버퍼링CheckoutQueue하는 Amazon SQS 대기열, AWS Lambda 이러한 주문을 처리하기 위해 대기열을 폴링CheckoutFunction하는 라는 함수, 수행된 모든 주문을 CheckoutTable 안전하게 저장하는 DynamoDB 테이블이 있습니다.
AWS Event Fork 파이프라인 적용
전자 상거래 애플리케이션의 구성 요소가 핵심 비즈니스 로직을 처리합니다. 그러나 전자 상거래 애플리케이션 소유자도 다음을 처리해야 합니다.
-
규정 준수—안전한 압축 백업(저장 시 암호화) 및 민감한 정보의 폐기
-
복원성—이행 프로세스 중단 시 최근 주문 다시 보기
-
검색 가능성—접수된 주문에 대한 분석 실행 및 지표 생성
이 이벤트 처리 로직을 구현하는 대신 애플리케이션 소유자는 CheckoutEventsTopic Amazon SNS 주제에 AWS Event Fork Pipelines을 구독할 수 있습니다.
-
이벤트 저장 및 백업 파이프라인 는 데이터를 변환하여 신용카드 세부 정보를 제거하고, 60초 동안 데이터를 버퍼링하고, 를 사용하여 데이터를 압축하고GZIP, Amazon S3의 기본 고객 관리형 키를 사용하여 암호화하도록 구성됩니다. 이 키는 AWS Key Management Service ()에서 관리 AWS 및 구동됩니다AWS KMS.
자세한 내용은 Amazon S3 Data Firehose 개발자 안내서의 대상 , Amazon Data Firehose 데이터 변환 및 설정 구성을 참조하세요.
-
이벤트 검색 및 분석 파이프라인은(는) 인덱스 재시도 지속시간 30초, 검색 도메인에서 인덱싱되지 않은 주문을 저장할 버킷, 인덱싱할 주문을 제한하는 필터 정책으로 구성되어 있습니다.
자세한 내용은 Amazon Data Firehose 개발자 안내서의 대상에 대한 OpenSearch 서비스 선택을 참조하세요.
-
이벤트 다시 보기 파이프라인 는 전자 상거래 애플리케이션 소유자가 설계하고 구현한 일반 주문 처리 파이프라인의 Amazon SQS 대기열 부분으로 구성됩니다.
자세한 내용은 Amazon Simple Queue Service 개발자 안내서의 대기열 이름 및 URL 섹션을 참조하세요.
다음 JSON 필터 정책은 이벤트 검색 및 분석 파이프라인의 구성에서 설정됩니다. 수신 주문 중 전체 금액이 $100 이상인 주문만 일치됩니다. 자세한 내용은 Amazon SNS 메시지 필터링 단원을 참조하십시오.
{
"amount": [{ "numeric": [ ">=", 100 ] }]
}전자 상거래 애플리케이션 소유자는 AWS Event Fork Pipelines 패턴을 사용하여 이벤트 처리를 위한 차별화되지 않는 로직 코딩을 따르는 개발 오버헤드를 피할 수 있습니다. 대신 에서 직접 AWS Event Fork 파이프라인을 AWS Serverless Application Repository 에 배포할 수 있습니다 AWS 계정.
