Amazon EventBridge 파이프 대상 - Amazon EventBridge
대상 파라미터권한간접 호출 대상AWS Batch 작업 대기열CloudWatch Logs 그룹Amazon ECS 태스크Lambda 함수 및 Step Functions 워크플로Timestream LiveAnalytics 테이블용

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

Amazon EventBridge 파이프 대상

파이프의 데이터를 특정 대상으로 보낼 수 있습니다. EventBridge에서 파이프를 설정할 때 다음 대상을 구성할 수 있습니다.

대상 파라미터

일부 대상 서비스는 이벤트 페이로드를 대상으로 보내지 않고 대신 이벤트를 특정 API를 간접 호출하는 트리거로 처리합니다. EventBridge는 PipeTargetParameters를 사용하여 해당 API로 전송할 정보를 지정합니다. 여기에는 다음이 포함됩니다.

  • API 대상(API 대상으로 전송되는 데이터는 API의 구조와 일치해야 합니다. InputTemplate 객체를 사용하여 데이터가 올바르게 구조화되었는지 확인해야 합니다. 원본 이벤트 페이로드를 포함하려면 InputTemplate에서 해당 페이로드를 참조하세요.)

  • API Gateway(API Gateway로 전송되는 데이터는 API의 구조와 일치해야 합니다. InputTemplate 객체를 사용하여 데이터가 올바르게 구조화되었는지 확인해야 합니다. 원본 이벤트 페이로드를 포함하려면 InputTemplate에서 해당 페이로드를 참조하세요.)

  • PipeTargetRedshiftDataParameters(Amazon Redshift Data API 클러스터)

  • PipeTargetSageMakerPipelineParameters(Amazon SageMaker 런타임 모델 구축 파이프라인)

  • PipeTargetBatchJobParameters (AWS Batch)

참고

EventBridge는 일부 JSON 경로 구문을 지원하며 런타임 시 이를 평가합니다. 지원되는 구문은 다음과 같습니다.

  • 점 표기법(예: $.detail)

  • 대시

  • 밑줄

  • 영숫자

  • 배열 인덱스

  • 와일드카드(*)

동적 경로 파라미터

EventBridge 파이프 대상 파라미터는 선택적인 동적 JSON 경로 구문을 지원합니다. 이 구문을 사용하여 정적 값 대신 JSON 경로를 지정할 수 있습니다(예: $.detail.state). 전체 값은 일부가 아닌 JSON 경로여야 합니다. 예를 들어 RedshiftParameters.Sql은 $.detail.state일 수 있지만 "SELECT * FROM $.detail.state"일 수는 없습니다. 이러한 경로는 런타임 시 지정된 경로에 있는 이벤트 페이로드 자체의 데이터로 동적으로 대체됩니다. 동적 경로 파라미터는 입력 변환으로 생성된 새 값이나 변환된 값을 참조할 수 없습니다. 동적 파라미터 JSON 경로에 지원되는 구문은 입력을 변환할 때와 동일합니다. 자세한 내용은 Amazon EventBridge Pipes 입력 변환 단원을 참조하십시오.

동적 구문은 다음을 제외하고 모든 EventBridge 파이프 보강 및 대상 파라미터의 모든 문자열, 비열거형 필드에 사용할 수 있습니다.

예를 들어 파이프 Kinesis 대상의 PartitionKey를 소스 이벤트의 사용자 지정 키로 설정하려면 KinesiStargetParameter.PartitionKey를 다음과 같이 설정합니다.

  • Kinesis 소스의 경우 "$.data.someKey"

  • Amazon SQS 소스의 경우 "$.body.someKey"

그러면 이벤트 페이로드가 유효한 JSON 문자열(예: {"someKey":"someValue"})인 경우 EventBridge는 JSON 경로에서 값을 추출하여 대상 파라미터로 사용합니다. 이 예에서 EventBridge는 Kinesis PartitionKey를 "someValue"로 설정합니다.

권한

소유하고 있는 리소스에 대해 API 직접 호출을 수행할 수 있으려면 EventBridge 파이프에 적절한 권한이 필요합니다. EventBridge 파이프는 IAM 보안 주체 pipes.amazonaws.com을 사용하여 보강 및 대상 호출을 위해 파이프에 지정하는 IAM 역할을 사용합니다.

간접 호출 대상

EventBridge는 다음과 같은 방법으로 대상을 간접 호출할 수 있습니다.

  • 동기식(간접 호출 유형이 REQUEST_RESPONSE로 설정됨) - EventBridge는 계속하기 전에 대상의 응답을 기다립니다.

  • 비동기식(간접 호출 유형이 FIRE_AND_FORGET으로 설정됨) - EventBridge는 계속 진행하기 전에 응답을 기다리지 않습니다.

기본적으로 순서가 지정된 소스가 있는 파이프의 경우 EventBridge는 대상을 동기식으로 간접 호출합니다. 다음 이벤트로 진행하기 전에 대상으로부터의 응답이 필요하기 때문입니다.

표준 Amazon SQS 대기열과 같이 소스가 순서를 적용하지 않는 경우 EventBridge는 지원되는 대상을 동기식 또는 비동기식으로 간접 호출할 수 있습니다.

Lambda 함수 및 Step Functions 상태 머신을 사용하여 간접 호출 유형을 구성할 수 있습니다.

참고

Step Functions 상태 머신의 경우 표준 워크플로를 비동기식으로 간접 호출해야 합니다.

AWS Batch 작업 대기열 대상 세부 정보

모든 AWS Batch submitJob 파라미터는 로 명시적으로 구성되며BatchParameters, 모든 파이프 파라미터와 마찬가지로 들어오는 이벤트 페이로드에 대한 JSON 경로를 사용하여 동적일 수 있습니다.

CloudWatch Logs 그룹 대상 세부 사항

입력 변환기를 사용하든 사용하지 않든, 이벤트 페이로드는 로그 메시지로 사용됩니다. PipeTarget의 CloudWatchLogsParameters를 통해 Timestamp(또는 대상의 명시적인 LogStreamName)를 설정할 수 있습니다. 모든 파이프 파라미터와 마찬가지로 수신 이벤트 페이로드에 대한 JSON 경로를 사용할 때 이러한 파라미터는 동적일 수 있습니다.

Amazon ECS 작업 대상 세부 사항

모든 Amazon ECS runTask 파라미터는 EcsParameters를 통해 명시적으로 구성됩니다. 모든 파이프 파라미터와 마찬가지로 수신 이벤트 페이로드에 대한 JSON 경로를 사용할 때 이러한 파라미터는 동적일 수 있습니다.

Lambda 함수 및 Step Functions 워크플로우 대상 세부 사항

Lambda 및 Step Functions에는 배치 API가 없습니다. 파이프 소스의 이벤트 배치를 처리하기 위해 배치는 JSON 배열로 변환되어 Lambda 또는 Step Functions 대상에 대한 입력으로 전달됩니다. 자세한 내용은 Amazon EventBridge 파이프 일괄 처리 및 동시성 단원을 참조하십시오.

Timestream LiveAnalytics 테이블 대상 세부 정보

Timestream for LiveAnalytics 테이블을 파이프 대상으로 지정할 때 고려할 사항은 다음과 같습니다.

  • Apache Kafka 스트림(Amazon MSK 또는 타사 공급자 포함)은 현재 파이프 소스로 지원되지 않습니다.

  • Kinesis 또는 DynamoDB 스트림을 파이프 소스로 지정한 경우 재시도 횟수를 지정해야 합니다.

    자세한 내용은 파이프 설정 구성 단원을 참조하십시오.