아마존 EventBridge 파이프 - Amazon EventBridge

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

아마존 EventBridge 파이프

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

참고

이벤트 버스를 사용하여 이벤트를 라우팅할 수도 있습니다. 이벤트 버스는 이벤트 기반 서비스 간에 이벤트를 many-to-many 라우팅하는 데 매우 적합합니다. 자세한 내용은 Amazon의 이벤트 버스 EventBridge 단원을 참조하십시오.

파이프 작동 방식 EventBridge

개괄적으로 EventBridge 파이프의 작동 원리는 다음과 같습니다.

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

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

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

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

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

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

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

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

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

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

소스는 파이프로 이벤트를 전송하며, 파이프는 일치하는 이벤트를 필터링하여 대상으로 라우팅합니다.

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

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

    • Amazon SQS 주문이 메시지 대기열을 이벤트 소스로 받았습니다.

    • 보강으로서의 EventBridge API 목적지

    • 타겟이 되는 AWS Step Functions 스테이트 머신

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

  3. 그러면 파이프가 해당 데이터를 EventBridge API 데스티네이션 인리치먼트로 전송하고 데스티네이션 인리치먼트는 해당 주문에 대한 고객 정보를 반환합니다.

  4. 마지막으로 파이프는 보강된 데이터를 AWS Step Functions 스테이트 머신으로 전송하고, 스테이트 머신은 주문을 처리합니다.