Amazon EventBridge Pipes

Amazon EventBridge 파이프는 소스를 대상에 연결합니다. 파이프는 지원되는 소스와 대상 간의 지점 간 통합을 위한 것으로 고급 변환 및 보강을 지원합니다. 이벤트 기반 아키텍처를 개발할 때 전문 지식 및 통합 코드의 필요성이 줄여 회사 애플리케이션 전반의 일관성을 높입니다. 파이프를 설정하려면 소스를 선택하고, 선택적 필터링을 추가하고, 선택적 보강을 정의하고, 이벤트 데이터의 대상을 선택합니다.

참고

이벤트 버스를 사용하여 이벤트를 라우팅할 수도 있습니다. 이벤트 버스는 이벤트 기반 서비스 간에 이벤트를 다대다 라우팅하는 데 적합합니다. 자세한 내용은 아마존 EventBridge 이벤트 버스 섹션을 참조하세요.

EventBridge 파이프 작동 방식

개괄적으로 살펴볼 때 EventBridge 파이프의 작동 방식은 다음과 같습니다.

1. 계정에서 파이프를 생성합니다. 여기에는 다음이 포함됩니다.

   • 파이프에서 이벤트를 수신할 지원되는 이벤트 소스 중 하나를 지정합니다.

   • 선택적으로 파이프가 소스로부터 수신한 이벤트의 하위 집합만 처리하도록 필터를 구성할 수 있습니다.

   • 선택적으로 이벤트 데이터를 대상으로 전송하기 전에 이벤트 데이터를 보강하는 보강 단계를 구성할 수 있습니다.

   • 파이프에서 이벤트를 전송할 지원되는 대상 중 하나를 지정합니다.

2. 이벤트 소스는 파이프로 이벤트를 보내기 시작하고 파이프는 이벤트를 처리한 다음 대상으로 전송합니다.

   • 필터를 구성한 경우 파이프는 이벤트를 평가하여 해당 필터와 일치하는 경우에만 대상으로 이벤트를 보냅니다.

     필터와 일치하는 이벤트에 대해서만 요금이 부과됩니다.

   • 보강을 구성한 경우 파이프는 이벤트를 대상으로 보내기 전에 이벤트에 대해 보강을 수행합니다.

     이벤트가 일괄 처리되는 경우 보강을 통해 일괄 처리에서 이벤트 순서가 유지됩니다.

예를 들어 파이프를 사용하여 전자 상거래 시스템을 만들 수 있습니다. 배송 주소와 같은 고객 정보가 포함된 API가 있다고 가정해 보겠습니다.

1. 그런 다음 다음을 사용하여 파이프를 생성합니다.

   • Amazon SQS 주문 수신 메시지 대기열을 이벤트 소스로 사용

   • EventBridge API 대상을 보강으로 사용

   • AWS Step Functions 상태 머신을 대상으로 사용

2. 그런 다음 Amazon SQS 주문 수신 메시지가 대기열에 나타나면 해당 메시지가 파이프로 전송됩니다.

3. 그런 다음 파이프는 해당 데이터를 EventBridge API 대상 보강으로 전송하고, EventBridge API 대상 보강은 해당 주문에 대한 고객 정보를 반환합니다.

4. 마지막으로 파이프는 보강된 데이터를 AWS Step Functions 상태 시스템으로 전송하고 상태 시스템은 주문을 처리합니다.