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

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

亚马逊 EventBridge 管道输入转换

Ama EventBridge zon 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 SQSbody 对象，也可以是 base64 编码的，例如 Kinesisdata 对象。对于筛选和输入转 EventBridge 换，将这些字段转换为有效的 JSON，以便可以直接引用子值。例如，对<$.data.someKey>于 Kinesis 来说。

要让目标接收原始有效载荷而无需任何其他元数据，请使用特定于源主体的输入转换器，其中包含该主体数据。例如，<$.body>适用于Amazon SQS 或 Kines<$.data> is。如果原始负载是有效的 JSON 字符串（例如{"key": "value"}），则将输入转换器与源特定主体数据一起使用将导致原始源负载中的引号被删除。例如，"{key: value}"在传送到目标时{"key": "value"}将变为。如果您的目标需要有效的 JSON 有效负载（例如 EventBridge Lambda 或 Step Functions），这将导致交付失败。要让目标在不生成无效的 JSON 的情况下接收原始源数据，请将源主体数据输入转换器封装在 JSON 中。例如，{"data": <$.data>}。

隐式正文解析也可以用于动态填充大多数管道目标或丰富参数的值。有关更多信息，请参阅 动态路径参数

转换输入的常见问题

以下是转换 EventBridge 管道中的输入时的一些常见问题：