EventBridge Pipe添加动态MessageGroupID时消息体被嵌套的问题

我使用EventBridge Pipe将普通SQS队列的消息转发至FIFO队列，通过JSONPath表达式从消息负载中取值设置为MessageGroupID，代码实现如下：

import { SqsTarget } from '@aws-cdk/aws-pipes-targets-alpha';
import { SqsSource } from '@aws-cdk/aws-pipes-sources-alpha';
import * as pipes from '@aws-cdk/aws-pipes-alpha';

const pipe = new pipes.Pipe(
      this,
      'pipe-name'),
      {
        source: new SqsSource(sourceQueueSQS),
        target: new SqsTarget(targetFifoQueue, {
          messageGroupId:  '$.body.detail.some.value.used.as.id',          
        }),
        role: pipeRole,
        pipeName: 'pipe-name',
      },
    );

目前MessageGroupID已按预期设置，但消息体（SQSEvent）被额外嵌套了一层body，导致下游Lambda的反序列化逻辑变得繁琐，请问该现象的原因是什么？

这是EventBridge Pipe的默认行为导致的：

• 当以SQS作为源时，Pipe会捕获完整的SQS消息结构（包含body、messageId、attributes、md5OfBody等所有元数据字段）作为传递给目标的负载。
• 若目标也是SQS且未配置输入转换，Pipe会将这整个完整结构原样放入目标消息的body中，从而形成嵌套——原始消息的内容被包裹在了新消息的body字段里。

举个直观的例子：
假设源SQS的消息体是{"detail": {"some": {"value": {"used": {"as": {"id": "group1"}}}}}}，经过默认转发后，目标FIFO队列的消息体结构会变成：

{
  "body": "{\"detail\": {\"some\": {\"value\": {\"used\": {\"as\": {\"id\": \"group1\"}}}}}",
  "messageId": "abc-123",
  "attributes": {
    "ApproximateReceiveCount": "1",
    // 其他SQS元数据
  }
}

如果要避免这种嵌套，只需给SqsTarget配置输入转换，直接提取源消息的body作为目标消息的内容。修改后的代码示例：

import { SqsTarget } from '@aws-cdk/aws-pipes-targets-alpha';
import { SqsSource } from '@aws-cdk/aws-pipes-sources-alpha';
import * as pipes from '@aws-cdk/aws-pipes-alpha';

const pipe = new pipes.Pipe(this, 'pipe-name', {
  source: new SqsSource(sourceQueueSQS),
  target: new SqsTarget(targetFifoQueue, {
    messageGroupId: '$.body.detail.some.value.used.as.id',
    // 配置输入转换，将源消息的body直接作为目标消息体
    input: pipes.Input.fromObject({
      body: pipes.EventField.fromPath('$.body'),
    }),
  }),
  role: pipeRole,
  pipeName: 'pipe-name',
});

如果原始消息的body是JSON字符串格式（而非JSON对象），可以改用Input.transform来直接传递原始内容：

// 替代上面的input配置
input: pipes.Input.transform({
  inputTemplate: '<$.body>',
}),

内容的提问来源于stack exchange，提问作者Richard Hudson