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

Amazon EventBridge Pipes 개념

여기서는 EventBridge 파이프의 기본 구성 요소를 자세히 살펴보겠습니다.

파이프

파이프는 단일 소스에서 단일 대상으로 이벤트를 라우팅합니다. 파이프에는 특정 이벤트를 필터링하고 이벤트 데이터가 대상으로 전송되기 전에 이벤트 데이터를 보강하는 기능도 포함되어 있습니다.

소스

EventBridge 파이프는 다양한 소스로부터 이벤트 데이터를 수신하고 해당 데이터에 선택적 필터 및 보강을 적용한 다음 이를 대상으로 보냅니다. 소스가 파이프로 전송된 이벤트에 순서를 적용하는 경우 해당 순서는 대상에 도달하는 전체 프로세스에서 유지됩니다.

소스에 대한 자세한 내용은 Amazon EventBridge 파이프 소스 단원을 참조하십시오.

필터

파이프는 특정 소스의 이벤트를 필터링한 다음 해당 이벤트의 일부만 처리할 수 있습니다. 파이프에 필터링을 구성하려면 파이프가 대상으로 전송할 이벤트를 결정하는 데 사용하는 이벤트 패턴을 정의합니다.

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

자세한 내용은 Amazon EventBridge Pipes의 이벤트 필터링 단원을 참조하십시오.

보강

EventBridge 파이프의 보강 단계에 따라 소스의 데이터를 대상으로 전송하기 전에 개선할 수 있습니다. 예를 들어 전체 티켓 데이터가 포함되지 않은 티켓 생성 이벤트를 수신할 수 있습니다. 보강을 사용하면 Lambda 함수로 get-ticket API를 호출하여 전체 티켓 세부 정보를 확인할 수 있습니다. 그 후 파이프가 해당 정보를 대상으로 전송할 수 있습니다.

이벤트 데이터 보강에 대한 자세한 내용은 Amazon EventBridge Pipes의 이벤트 보강 단원을 참조하세요.

대상

이벤트 데이터를 필터링하고 보강한 후에는 파이프가 Amazon Kinesis 스트림 또는 Amazon CloudWatch 로그 그룹과 같은 특정 대상으로 전송하도록 지정할 수 있습니다. 사용 가능한 대상 목록은 Amazon EventBridge 파이프 대상 단원을 참조하세요.

데이터가 개선된 후와 파이프를 통해 대상으로 전송되기 전에 데이터를 변환할 수 있습니다. 자세한 내용은 Amazon EventBridge Pipes 입력 변환 단원을 참조하십시오.

각각 소스가 다른 여러 파이프는 동일한 대상으로 이벤트를 전송할 수 있습니다.

파이프와 이벤트 버스를 함께 사용하여 여러 대상에 이벤트를 보낼 수도 있습니다. 일반적인 사용 사례는 이벤트 버스를 대상으로 하는 파이프를 만드는 것입니다. 이 파이프는 이벤트를 이벤트 버스로 보낸 다음 이벤트 버스가 해당 이벤트를 여러 대상으로 전송합니다. 예를 들어, 소스용 DynamoDB 스트림과 대상 이벤트 버스를 사용하여 파이프를 생성할 수 있습니다. 파이프는 DynamoDB 스트림에서 이벤트를 수신하여 이벤트 버스로 전송합니다. 그런 다음 이벤트 버스에서 지정한 규칙에 따라 이벤트를 여러 대상으로 전송합니다.