Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

Amazon EventBridge Pipes 输入转换

Amazon EventBridge Pipes 在向富集和目标传递数据时，支持可选的输入转换器。您可以使用输入转换器来重塑 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 管道中转换输入时会遇到的一些常见问题：