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

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

아마존 EventBridge 파이프 생성

EventBridge Pipes를 사용하면 고급 이벤트 변환 및 강화를 포함하여 소스와 대상 간의 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 Cloud 스트림을 소스로 구성하려면

    1. 소스에서 컨플루언트 클라우드를 선택합니다.

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

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

    4. (선택 사항 VPC) 에서 원하는 VPC 것을 선택하십시오. 그런 다음 VPC서브넷의 경우 원하는 서브넷을 선택합니다. VPC보안 그룹의 경우 보안 그룹을 선택합니다.

    5. 인증 (선택 사항) 의 경우 인증 사용을 켜고 다음을 수행하십시오.

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

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

      자세한 내용은 Confluent 설명서에서 Confluent Cloud 리소스에 대한 인증을 참조하십시오.

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

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

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

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

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

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

    DynamoDB

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

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

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

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

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

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

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

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

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

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

        • AUTOMATIC_ BISECT — 각 배치를 반으로 줄이고 모든 레코드가 처리되거나 배치에 하나의 실패 메시지가 남아 있을 때까지 각 배치를 다시 시도하십시오.

        참고

        AUTOMATICBISECT_를 선택하지 않으면 실패한 특정 레코드를 반환할 수 있으며 해당 레코드만 다시 시도됩니다.

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

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

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

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

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

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

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

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

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

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

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

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

        • AUTOMATIC_ BISECT - 각 일괄 처리를 절반으로 줄이고 모든 레코드가 처리되거나 일괄 처리에 실패 메시지가 한 개 남아 있을 때까지 각 일괄 처리를 다시 시도합니다.

        참고

        AUTOMATICBISECT_를 선택하지 않으면 실패한 특정 레코드를 반환할 수 있으며 해당 레코드만 다시 시도됩니다.

    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 Gateway 또는 대상으로 이벤트 데이터를 전송할 수 있습니다. API 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. (선택 사항) a 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) 를 사용하려면 데드레터 큐를 켜고 원하는 방법을 선택한 다음 사용하려는 대기열이나 주제를 선택합니다. 기본적으로 새로 만든 파이프에서는 a를 사용하지 않습니다. DLQ

  5. (선택 사항) 로그 - 선택 사항에서 해당 로그를 구성하는 방법을 비롯해 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 포맷할 방법을 선택합니다.

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

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

구성 파라미터 검증

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

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

    참고

    EventBridge 인리치먼트나 타겟은 파이프가 생성된 후에 업데이트될 수 있으므로 동일한 검증을 수행하지 않습니다.

  • 일괄 처리 — 소스의 배치 크기가 대상의 최대 배치 크기를 초과하지 않는지 EventBridge 검증합니다. 그럴 경우 배치 크기를 EventBridge 줄여야 합니다. 또한 대상이 일괄 처리를 지원하지 않는 경우 소스에 EventBridge 대해 일괄 처리를 구성할 수 없습니다.

  • 강화 — 배치 크기 1만 지원되므로 API 게이트웨이 및 API 대상 강화의 배치 크기가 1인지 EventBridge 확인합니다.