Amazon EventBridge Pipes 입력 변환

Amazon EventBridge 파이프는 데이터를 보강과 대상으로 전달할 때 선택적 입력 변환기를 지원합니다. 입력 변환기를 사용하여 보강 또는 대상 서비스의 요구 사항에 맞게 JSON 이벤트 입력 페이로드를 재구성할 수 있습니다. Amazon API Gateway 및 API 대상의 경우 다음과 같이 입력 이벤트를 API의 RESTful 모델에 맞출 수 있습니다. 입력 변환기는 InputTemplate 파라미터로 모델링됩니다. 자유 텍스트, 이벤트 페이로드의 JSON 경로 또는 이벤트 페이로드에 대한 인라인 JSON 경로를 포함하는 JSON 객체일 수 있습니다. 보강을 위해 이벤트 페이로드는 소스에서 가져옵니다. 대상의 경우 파이프에 구성된 경우 보강에서 반환되는 것이 이벤트 페이로드입니다. 이벤트 페이로드의 서비스별 데이터 외에도 InputTemplate의 예약 변수를 사용하여 파이프의 데이터를 참조할 수 있습니다.

배열의 항목에 액세스하려면 대괄호 표기법을 사용하세요.

다음은 Amazon SQS 이벤트 페이로드를 참조하는 샘플 InputTemplate 파라미터입니다.

정적 문자열

InputTemplate: "Hello, sender"

JSON 경로

InputTemplate: <$.attributes.SenderId>

동적 문자열

InputTemplate: "Hello, <$.attributes.SenderId>"

정적 JSON

InputTemplate: >
{
  "key1": "value1",
  "key2": "value2",
  "key3": "value3",
}

다이나믹 JSON

InputTemplate: >
{
  "key1": "value1"
  "key2": <$.body.key>,
  "d": <aws.pipes.event.ingestion-time>
}

대괄호 표기법을 사용하여 배열의 항목에 액세스합니다.

InputTemplate: >
{
  "key1": "value1"
  "key2": <$.body.Records[3]>,
  "d": <aws.pipes.event.ingestion-time>
}

예약된 변수

입력 템플릿은 다음 예약된 변수를 사용할 수 있습니다.

입력 변환 예제

다음은 샘플 이벤트로 사용할 수 있는 Amazon EC2 이벤트의 예입니다.

{
  "version": "0",
  "id": "7bf73129-1428-4cd3-a780-95db273d1602",
  "detail-type": "EC2 Instance State-change Notification",
  "source": "aws.ec2",
  "account": "123456789012",
  "time": "2015-11-11T21:29:54Z",
  "region": "us-east-1",
  "resources": [
    "arn:aws:ec2:us-east-1:123456789012:instance/i-abcd1111"
  ],
  "detail": {
    "instance-id": "i-0123456789",
    "state": "RUNNING"
  }
}
		

다음 JSON을 변환기로 사용하겠습니다.

{
  "instance" : <$.detail.instance-id>,
  "state": <$.detail.state>,
  "pipeArn" : <aws.pipes.pipe-arn>,
  "pipeName" : <aws.pipes.pipe-name>,
  "originalEvent" : <aws.pipes.event.json>
}

결과 출력은 다음과 같습니다.

{
  "instance" : "i-0123456789",
  "state": "RUNNING",
  "pipeArn" : "arn:aws:pipe:us-east-1:123456789012:pipe/example",
  "pipeName" : "example",
  "originalEvent" : {
    ... // commented for brevity
  }
}

암시적 본문 데이터 구문 분석

수신 페이로드의 다음 필드는 JSON으로 이스케이프 처리되거나(예: Amazon SQS body 객체) base64로 인코딩될 수 있습니다(예: Kinesis data 객체). 필터링과 입력 변환 모두에서 EventBridge는 이러한 필드를 유효한 JSON으로 변환하므로 하위 값을 직접 참조할 수 있습니다. 예를 들어, Kinesis의 경우 <$.data.someKey>입니다.

추가 메타데이터 없이 대상이 원본 페이로드를 수신하도록 하려면 소스별 본문 데이터와 함께 입력 변환기를 사용하세요. Amazon SQS의 경우 <$.body>, Kinesis의 경우 <$.data>를 예로 들 수 있습니다. 원본 페이로드가 유효한 JSON 문자열(예: {"key": "value"})인 경우 소스별 본문 데이터와 함께 입력 변환기를 사용하면 원본 소스 페이로드 내의 따옴표가 제거됩니다. 예를 들어, {"key": "value"}는 대상에 전달되면 "{key: value}"가 됩니다. 대상에 유효한 JSON 페이로드(예: EventBridge Lambda 또는 Step Functions)가 필요한 경우 전송이 실패합니다. 잘못된 JSON을 생성하지 않고 대상이 원본 소스 데이터를 수신하도록 하려면 소스 본문 데이터 입력 변환기를 JSON으로 래핑하세요. 예: {"data": <$.data>}.

암시적 본문 구문 분석을 사용하여 대부분의 파이프 대상 또는 보강 파라미터의 값을 동적으로 채울 수도 있습니다. 자세한 내용은 동적 경로 파라미터 단원을 참조하세요.

입력 변환과 관련된 일반적인 문제

다음은 EventBridge 파이프에서 입력을 변환할 때 발생하는 몇 가지 일반적인 문제입니다.