Amazon EventBridge 파이프 생성 - Amazon EventBridge
소스 지정필터링 구성보강 정의대상 구성파이프 설정 구성구성 파라미터 검증

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

Amazon EventBridge 파이프 생성

EventBridge 파이프를 사용하면 고급 이벤트 변환 및 보강을 포함하여 소스와 대상 간의 point-to-point 통합을 생성할 수 있습니다. EventBridge 파이프를 생성하려면 다음 단계를 수행합니다.

  1. 소스 지정

  2. 이벤트 필터링 구성(선택 사항)

  3. 이벤트 보강 정의(선택 사항)

  4. 대상 구성

  5. 파이프 설정 구성

를 사용하여 파이프를 생성하는 방법에 대한 자세한 내용은 AWS CLI 명령 참조의 create-pipe를 AWS CLI참조하세요.

소스 지정

시작하려면 파이프에서 이벤트를 수신할 소스를 지정합니다.

콘솔을 사용하여 파이프 소스를 지정하려면

  1. 에서 Amazon EventBridge 콘솔을 엽니다https://console.aws.amazon.com/events/.

  2. 탐색 창에서 파이프를 선택합니다.

  3. 파이프 생성을 선택합니다.

  4. 파이프 이름을 입력합니다.

  5. (선택 사항) 파이프에 대한 설명을 추가합니다.

  6. 파이프 만들기 탭의 소스에서 이 파이프에 지정할 소스 유형을 선택하고 소스를 구성합니다.

    구성 속성은 선택한 소스 유형에 따라 다릅니다.

    Confluent
    콘솔을 사용하여 Confluent 클라우드 스트림을 소스로 구성하려면

    1. 소스 에서 Confluent 클라우드 를 선택합니다.

    2. 부트스트랩 서버의 경우 브로커의 host:port 쌍 주소를 입력합니다.

    3. 주제 이름에 파이프가 읽을 주제의 이름을 입력합니다.

    4. (선택 사항) 에서 원하는 VPC를 VPC선택합니다. 그런 다음 VPC 서브넷 에서 원하는 서브넷을 선택합니다. VPC 보안 그룹 에서 보안 그룹을 선택합니다.

    5. 인증 - 선택 사항인 경우 인증 사용을 켜고 다음을 수행합니다.

      1. 인증 방법에서 인증 유형을 선택합니다.

      2. 비밀 키에서 비밀 키를 선택합니다.

      자세한 내용은 Confluent 설명서의 Authenticate to Confluent Cloud 리소스를 참조하세요.

    6. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 시작 위치에는 다음 중 하나를 선택합니다.

        • 최신 - 샤드에 있는 최근 레코드로 스트림 읽기를 시작합니다.

        • 트림 호라이즌 - 샤드에서 트리밍되지 않은 마지막 레코드로 스트림 읽기를 시작합니다. 샤드에서 가장 오래된 레코드입니다.

      2. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      3. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

    DynamoDB

    1. 소스에서 DynamoDB를 선택합니다.

    2. DynamoDB 스트림의 경우 소스로 사용할 스트림을 선택합니다.

    3. 시작 위치에는 다음 중 하나를 선택합니다.

      • 최신 - 샤드에 있는 최근 레코드로 스트림 읽기를 시작합니다.

      • 트림 호라이즌 - 샤드에서 트리밍되지 않은 마지막 레코드로 스트림 읽기를 시작합니다. 샤드에서 가장 오래된 레코드입니다.

    4. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      2. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

      3. 샤드당 동시 배치 - 선택 사항에는 동시에 읽을 수 있는 동일한 샤드의 배치 수를 입력합니다.

      4. 부분 배치 항목 실패 시의 경우 다음을 선택합니다.

        • AUTOMATIC_BISECT - 각 배치를 절반으로 줄이고 모든 레코드가 처리되거나 배치에 실패 메시지가 하나 남을 때까지 각 반씩 다시 시도합니다.

        참고

        AUTOMATIC_BISECT를 선택하지 않으면 실패한 특정 레코드와 재시도된 레코드만 반환할 수 있습니다.

    Kinesis
    콘솔을 사용하여 Kinesis 소스를 구성하려면

    1. 소스에서 Kinesis를 선택합니다.

    2. Kinesis 스트림의 경우 소스로 사용할 스트림을 선택합니다.

    3. 시작 위치에는 다음 중 하나를 선택합니다.

      • 최신 - 샤드에 있는 최근 레코드로 스트림 읽기를 시작합니다.

      • 트림 호라이즌 - 샤드에서 트리밍되지 않은 마지막 레코드로 스트림 읽기를 시작합니다. 샤드에서 가장 오래된 레코드입니다.

      • 타임 스탬프에서 - 지정된 시간부터 스트림 읽기를 시작합니다. 타임스탬프 에서 YYYY/MM/DD 및 hh:mm:ss 형식을 사용하여 데이터 및 시간을 입력합니다.

    4. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      2. (선택 사항) 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

      3. 샤드당 동시 배치 - 선택 사항에는 동시에 읽을 수 있는 동일한 샤드의 배치 수를 입력합니다.

      4. 부분 배치 항목 실패 시의 경우 다음을 선택합니다.

        • AUTOMATIC_BISECT – 각 배치를 절반으로 줄이고 모든 레코드가 처리되거나 배치에 실패 메시지가 하나 남을 때까지 각 반씩 다시 시도합니다.

        참고

        AUTOMATIC_BISECT를 선택하지 않으면 실패한 특정 레코드와 재시도된 레코드만 반환할 수 있습니다.

    Amazon MQ
    콘솔을 사용하여 Amazon MQ 소스를 구성하려면

    1. 소스에서 Amazon MQ를 선택합니다.

    2. Amazon MQ 브로커의 경우 소스로 사용할 스트림을 선택합니다.

    3. 대기열 이름에 파이프가 읽을 대기열의 이름을 입력합니다.

    4. 인증 방법 에서 BASIC_AUTH를 선택합니다.

    5. 비밀 키에서 비밀 키를 선택합니다.

    6. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 배치 크기 - 선택 사항에는 각 배치의 최대 메시지 수를 입력합니다. 기본 값은 100입니다.

      2. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

    Amazon MSK
    콘솔을 사용하여 Amazon MSK 소스를 구성하려면

    1. 소스 에서 Amazon 을 MSK선택합니다.

    2. Amazon MSK 클러스터 에서 사용할 클러스터를 선택합니다.

    3. 주제 이름에 파이프가 읽을 주제의 이름을 입력합니다.

    4. (선택 사항) 소비자 그룹 ID - 선택 사항에서 파이프를 조인할 소비자 그룹의 ID를 입력합니다.

    5. (선택 사항) 인증 - 선택 사항의 경우 인증 사용을 설정하고 다음을 수행합니다.

      1. 인증 방법에서 원하는 유형을 선택합니다.

      2. 비밀 키에서 비밀 키를 선택합니다.

    6. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      2. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

      3. 시작 위치에는 다음 중 하나를 선택합니다.

        • 최신 - 샤드에 있는 최근 레코드로 주제 읽기를 시작합니다.

        • 트림 호라이즌 - 샤드에서 트리밍되지 않은 마지막 레코드로 주제 읽기를 시작합니다. 샤드에서 가장 오래된 레코드입니다.

          참고

          트림 호라이즌은 Apache Kafka의 가장 빠른 항목과 동일합니다.

    Self managed Apache Kafka
    콘솔을 사용하여 자체 관리형 Apache Kafka 소스를 구성하려면

    1. 소스에서 자체 관리형 Apache Kafka를 선택합니다.

    2. 부트스트랩 서버의 경우 브로커의 host:port 쌍 주소를 입력합니다.

    3. 주제 이름에 파이프가 읽을 주제의 이름을 입력합니다.

    4. (선택 사항) 에서 원하는 VPC를 VPC선택합니다. 그런 다음 VPC 서브넷 에서 원하는 서브넷을 선택합니다. VPC 보안 그룹 에서 보안 그룹을 선택합니다.

    5. (선택 사항) 인증 - 선택 사항의 경우 인증 사용을 설정하고 다음을 수행합니다.

      1. 인증 방법에서 인증 유형을 선택합니다.

      2. 비밀 키에서 비밀 키를 선택합니다.

    6. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 시작 위치에는 다음 중 하나를 선택합니다.

        • 최신 - 샤드에 있는 최근 레코드로 스트림 읽기를 시작합니다.

        • 트림 호라이즌 - 샤드에서 트리밍되지 않은 마지막 레코드로 스트림 읽기를 시작합니다. 샤드에서 가장 오래된 레코드입니다.

      2. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      3. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

    Amazon SQS
    콘솔을 사용하여 Amazon SQS 소스를 구성하려면

    1. 소스스(Source)에 SQS를 선택합니다.

    2. SQS 대기열 에서 사용할 대기열을 선택합니다.

    3. (선택 사항) 추가 설정 - 선택 사항에서 다음을 수행합니다.

      1. 배치 크기 - 선택 사항에는 각 배치의 최대 레코드 수를 입력합니다. 기본 값은 100입니다.

      2. 배치 기간 - 선택 사항의 경우 진행하기 전에 레코드를 수집할 최대 시간(초)을 입력합니다.

이벤트 필터링 구성(선택 사항)

소스에서 대상으로 이벤트의 하위 집합만 전송하도록 파이프에 필터링을 추가할 수 있습니다.

콘솔을 사용하여 필터링을 구성하려면

  1. 필터링을 선택합니다.

  2. 샘플 이벤트 - 선택 사항에는 이벤트 패턴을 작성하는 데 사용할 수 있는 샘플 이벤트가 표시되거나 직접 입력을 선택하여 자체 이벤트를 입력할 수 있습니다.

  3. 이벤트 패턴에서 이벤트를 필터링하는 데 사용할 이벤트 패턴을 입력합니다. 필터 구성에 대한 자세한 내용은 섹션을 참조하세요Amazon EventBridge 파이프의 이벤트 필터링.

    다음은 City 필드에 Seattle 값이 있는 이벤트만 보내는 이벤트 패턴의 예입니다.

    {
  "data": {
    "City": ["Seattle"]
  }
}

이제 이벤트가 필터링되었으므로 파이프에 선택적 보강과 대상을 추가할 수 있습니다.

이벤트 보강 정의(선택 사항)

Lambda 함수, AWS Step Functions 상태 시스템, Amazon API Gateway 또는 API 대상으로 보강을 위해 이벤트 데이터를 전송할 수 있습니다.

보강을 선택하려면

  1. 보강을 선택합니다.

  2. 세부 정보의 서비스에서 보강에 사용할 서비스 및 관련 설정을 선택합니다.

데이터를 개선하도록 전송하기 전에 데이터를 변환할 수도 있습니다.

(선택 사항) 입력 변환기를 정의하려면

  1. 보강 입력 변환기 - 선택 사항을 선택합니다.

  2. 샘플 이벤트/이벤트 페이로드에서 샘플 이벤트 유형을 선택합니다.

  3. 변환기에는 "Event happened at <$.detail.field>."와 같은 변환기 구문을 입력합니다. 여기서 <$.detail.field>는 샘플 이벤트의 필드에 대한 참조입니다. 샘플 이벤트의 필드를 두 번 클릭하여 변환기에 추가할 수도 있습니다.

  4. 출력의 경우 출력이 원하는 대로 표시되는지 확인합니다.

이제 데이터가 필터링되고 개선되었으므로 이벤트 데이터를 전송할 대상을 정의해야 합니다.

대상 구성

대상을 구성하려면

  1. [Target]을 선택합니다.

  2. 세부 정보의 대상 서비스에서 대상을 선택합니다. 표시되는 필드는 선택한 대상에 따라 달라집니다. 필요에 따라 이 대상 유형과 관련된 정보를 입력합니다.

데이터를 대상으로 전송하기 전에 데이터를 변환할 수도 있습니다.

(선택 사항) 입력 변환기를 정의하려면

  1. 대상 입력 변환기 - 선택 사항을 선택합니다.

  2. 샘플 이벤트/이벤트 페이로드에서 샘플 이벤트 유형을 선택합니다.

  3. 변환기에는 "Event happened at <$.detail.field>."와 같은 변환기 구문을 입력합니다. 여기서 <$.detail.field>는 샘플 이벤트의 필드에 대한 참조입니다. 샘플 이벤트의 필드를 두 번 클릭하여 변환기에 추가할 수도 있습니다.

  4. 출력의 경우 출력이 원하는 대로 표시되는지 확인합니다.

이제 파이프가 구성되었으므로 해당 설정이 올바르게 구성되었는지 확인하세요.

파이프 설정 구성

파이프는 기본적으로 활성화되지만 비활성화할 수 있습니다. 파이프에 대한 권한을 지정하고, 파이프 로깅을 설정하고, 태그를 추가할 수도 있습니다.

파이프 설정을 구성하려면

  1. 파이프 설정 탭을 선택합니다.

  2. 기본적으로 새로 생성된 파이프는 생성되는 즉시 활성화됩니다. 비활성 파이프를 생성하려면 활성화의 파이프 활성화에서 활성을 끕니다.

  3. 권한의 실행 역할에서 다음 중 하나를 수행합니다.

    1. 이 파이프에 대한 새 실행 역할을 EventBridge 생성하려면 이 특정 리소스에 대한 새 역할 생성을 선택합니다. 역할 이름에서 선택적으로 역할 이름을 편집할 수 있습니다.

    2. 기존 실행 역할을 사용하려면 기존 역할 사용을 선택합니다. 역할 이름에서 역할을 선택합니다.

  4. (선택 사항) Kinesis 또는 DynamoDB 스트림을 파이프 소스로 지정한 경우 재시도 정책 및 데드 레터 대기열()을 구성할 수 있습니다DLQ.

    재시도 정책 및 DLQ(Dead Letter Queue) - 선택 사항에서 다음을 수행합니다.

    재시도 정책에서 다음을 수행합니다.

    1. 재시도 정책을 설정하려면 재시도를 켭니다. 기본적으로 새로 생성된 파이프에는 재시도 정책이 설정되어 있지 않습니다.

    2. 최대 이벤트 기간(Maximum age of event)에 1분(00:01)에서 24시간(24:00) 사이의 값을 입력합니다.

    3. 재시도(Retry attempts)에 0에서 185 사이의 숫자를 입력합니다.

    4. 데드 레터 대기열(DLQ)을 사용하려면 데드 레터 대기열을 켜고 원하는 방법을 선택한 다음 사용하려는 대기열 또는 주제를 선택합니다. 기본적으로 새로 생성된 파이프는 를 사용하지 않습니다DLQ.

  5. 파이프 데이터를 암호화 EventBridge 할 때 사용할 KMS key 를 선택합니다.

    가 EventBridge 를 사용하는 방법에 대한 자세한 내용은 섹션을 KMS keys참조하세요저장 중 암호화.

    • EventBridge 에 사용을 AWS 소유 키 선택하여 를 사용하여 데이터를 암호화합니다 AWS 소유 키.

      이는 여러 AWS 계정에서 사용할 를 KMS key EventBridge 소유하고 관리하는 AWS 소유 키 입니다. 일반적으로 리소스를 보호하는 암호화 키를 감사하거나 제어해야 하는 경우가 아니라면 를 AWS 소유 키 선택하는 것이 좋습니다.

      이 값이 기본값입니다.

    • EventBridge 에 사용을 고객 관리형 키 선택하여 지정하거나 생성한 를 사용하여 데이터를 암호화 고객 관리형 키 합니다.

      고객 관리형 키 는 사용자가 생성, 소유 및 관리하는 AWS 계정에 KMS keys 있습니다. 이러한 를 완전히 제어할 수 있습니다 KMS keys.

      1. 기존 를 지정 고객 관리형 키하거나 새 생성 을 KMS key 선택합니다.

        EventBridge 는 키 상태와 지정된 와 연결된 모든 키 별칭을 표시합니다 고객 관리형 키.

  6. (선택 사항) 로그 - 선택 사항에서 해당 로그를 구성하는 방법을 비롯해 EventBridge 파이프가 지원되는 서비스에 로깅 정보를 보내는 방법을 설정할 수 있습니다.

    파이프 레코드 로깅에 대한 자세한 내용은 아마존 EventBridge 파이프 퍼포먼스 로깅 섹션을 참조하세요.

    CloudWatch 로그는 로그 수준과 마찬가지로 기본적으로 ERROR 로그 대상으로 선택됩니다. 따라서 기본적으로 EventBridge Pipes는 세부 ERROR 정보가 포함된 CloudWatch 로그 레코드를 보내는 새 로그 그룹을 생성합니다.

    EventBridge Pipes가 지원되는 로그 대상으로 로그 레코드를 보내도록 하려면 다음을 수행합니다.

    1. 로그 - 선택 사항에서 로그 레코드를 전송할 대상을 선택합니다.

    2. 로그 수준 에서 로그 레코드에 EventBridge 포함할 의 정보 수준을 선택합니다. ERROR 로그 수준이 기본적으로 선택됩니다.

      자세한 내용은 EventBridge 파이프 로그 수준 지정 단원을 참조하십시오.

    3. 로그 레코드 EventBridge 에 이벤트 페이로드 정보, 서비스 요청 및 응답 정보를 포함하려면 실행 데이터 포함을 선택합니다.

      자세한 내용은 EventBridge Pipes 로그에 실행 데이터 포함 단원을 참조하십시오.

    4. 선택한 각 로그 대상을 구성합니다.

      CloudWatch Logs 로그의 경우 CloudWatch 로그에서 다음을 수행합니다.

      • CloudWatch 로그 그룹 의 경우 새 로그 그룹을 EventBridge 생성할지 또는 기존 로그 그룹을 선택하거나 기존 로그 그룹의 ARN를 지정할지 선택합니다.

      • 새 로그 그룹의 경우 원하는 대로 로그 그룹 이름을 편집합니다.

      CloudWatch 로그는 기본적으로 선택됩니다.

      Firehose 스트림 로그의 경우 Firehose 스트림 로그 아래에서 Firehose 스트림을 선택합니다.

      Amazon S3 로그의 경우 S3 로그에서 다음을 수행합니다.

      • 로그 대상으로 사용할 버킷 이름을 입력합니다.

      • 버킷 소유자의 AWS 계정 ID를 입력합니다.

      • EventBridge 가 S3 객체를 생성할 때 사용할 접두사 텍스트를 입력합니다.

        자세한 내용은 Amazon Simple Storage Service 사용 설명서에서 접두어를 사용한 객체 구성을 참조하세요.

      • S3 로그 레코드 EventBridge 의 형식을 지정하는 방법을 선택합니다.

  7. (선택 사항) 태그 - 선택 사항에서 새 태그 추가를 선택하고 규칙에 대해 하나 이상의 태그를 입력합니다. 자세한 내용은 Amazon의 리소스 태깅 EventBridge 단원을 참조하십시오.

  8. 파이프 생성을 선택합니다.

구성 파라미터 검증

파이프가 생성된 후 는 다음 구성 파라미터를 EventBridge 검증합니다.

  • IAM 역할 - 파이프가 생성된 후에는 파이프의 소스를 변경할 수 없으므로 는 제공된 IAM 역할이 소스에 액세스할 수 있는지 EventBridge 확인합니다.

    참고

    EventBridge 는 파이프가 생성된 후 업데이트할 수 있으므로 강화 또는 대상에 대해 동일한 검증을 수행하지 않습니다.

  • 배치화 - 소스의 배치 크기가 대상의 최대 배치 크기를 초과하지 않는지 EventBridge 확인합니다. 그렇다면 배치 크기를 줄여야 EventBridge 합니다. 또한 대상이 배치화를 지원하지 않는 경우 소스에 EventBridge 대해 배치화를 구성할 수 없습니다.

  • 보강 - 배치 크기가 1인 경우에만 지원되므로 API Gateway 및 API 대상 보강의 배치 크기가 1인지 EventBridge 확인합니다.