翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon EventBridge Pipes 入力変換

Amazon EventBridge Pipes は、エンリッチメントとターゲットにデータを渡すときに、オプションの入力トランスフォーマーをサポートします。入力トランスフォーマーを使用して、エンリッチメントまたはターゲットサービスのニーズに対応するためにJSONイベント入力ペイロードを再形成できます。Amazon API Gateway とAPI送信先の場合、入力イベントを のRESTfulモデルに形成する方法は次のとおりですAPI。Input Transformer は 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>
}

予約変数

入力テンプレートは次の予約変数を使用できます。

入力変換の例

以下は、サンプルEC2イベント として使用できる Amazon イベントの例です。

{
  "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
  }
}

暗示的な本文データ解析

受信ペイロードの次のフィールドは、Amazon SQS body オブジェクトなどの JSONエスケープ、または Kinesis data オブジェクトなどの base64 エンコードできます。フィルタリングと入力変換の両方で、 はこれらのフィールドを有効な EventBridge に変換JSONし、サブ値を直接参照できるようにします。例えば、<$.data.someKey> は Kinesis 場合です。

追加のメタデータなしでターゲットが元のペイロードを受け取れるようにするには、ソース固有のこの本文データを含む Input Transformer を使用します。例えば、Amazon <$.body>の場合は SQS、Kinesis <$.data>の場合は です。元のペイロードが有効なJSON文字列 (例: {"key": "value"}) である場合、ソース固有の本文データで入力トランスフォーマーを使用すると、元のソースペイロード内の引用符が削除されます。例えば、{"key": "value"} は、ターゲットに配信されたとき "{key: value}" になります。ターゲットに有効なJSONペイロード ( EventBridge Lambda や Step Functions など) が必要な場合は、配信に失敗します。無効な を生成せずにターゲットに元のソースデータを受信させるにはJSON、ソースボディデータ入力トランスフォーマーを でラップしますJSON。例えば、{"data": <$.data>} と指定します。

また、暗示的な本文解析を使用すると、ほとんどのパイプターゲットまたはエンリッチメントパラメータの値を動的に入力することができます。詳細については、「動的パスパラメータ」を参照してください

入力変換に関する一般的な問題

EventBridge パイプの入力を変換する際の一般的な問題は次のとおりです。