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

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

아마존 EventBridge 파이프 타겟

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

대상 파라미터

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

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

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

  • PipeTargetRedshiftDataParameters(아마존 Redshift 데이터 API 클러스터)

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

  • PipeTargetBatchJobParameters (AWS Batch)

참고

EventBridge 모든 JSON Path 구문을 지원하지는 않으며 런타임에 이를 평가합니다. 지원되는 구문은 다음과 같습니다.

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

  • 대시

  • 밑줄

  • 영숫자

  • 배열 인덱스

  • 와일드카드(*)

동적 경로 파라미터

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

동적 구문은 다음을 제외한 모든 EventBridge Pipes 보강 및 대상 매개변수의 모든 문자열, 비열거형 필드에 사용할 수 있습니다.

예를 들어 파이프 Kinesis 대상을 소스 이벤트의 사용자 지정 키로 설정하려면 를 설정하십시오. PartitionKey KinesisTargetParameter PartitionKey다음으로:

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

  • "$.body.someKey"아마존 SQS 소스의 경우

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

권한

소유한 리소스를 API 호출하려면 Pipes에 적절한 권한이 있어야 합니다. EventBridge EventBridge PIpes파이프에서 지정한 IAM 역할을 사용하여 통화를 강화하고 보안 주체를 사용하여 통화를 타깃팅합니다IAM. pipes.amazonaws.com

간접 호출 대상

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

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

  • 비동기적으로 (호출 유형을 로 설정FIRE_AND_FORGET) - 응답을 EventBridge 기다리지 않고 계속 진행합니다.

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

표준 Amazon SQS 대기열과 같은 소스가 주문을 적용하지 않는 경우 지원되는 대상을 동기적으로 또는 비동기적으로 EventBridge 호출할 수 있습니다.

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

참고

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

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

모든 AWS Batch submitJob 매개 변수는 모든 Pipe 매개 변수를 사용하여 명시적으로 구성되며BatchParameters, 모든 Pipe 매개 변수와 마찬가지로 수신 이벤트 페이로드의 JSON 경로를 사용하여 동적으로 구성할 수 있습니다.

CloudWatch 로그는 대상 세부 정보를 그룹화합니다.

입력 변환기를 사용하든 사용하지 않든, 이벤트 페이로드는 로그 메시지로 사용됩니다. 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 Pipes 일괄 처리 및 동시성 단원을 참조하십시오.

Timestream 테이블 대상 세부 사항용 LiveAnalytics

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

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

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

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