EventBridge Pipes目标输入转换器：DynamoDB列表格式转换难题

AI 小北

2026-8-6

解决方案

1. 使用VTL模板处理动态数组（推荐）

EventBridge Pipes支持Velocity Template Language（VTL）作为输入转换模板，比单纯的JSONPath映射更灵活，能轻松处理动态长度的列表。

在Pipes的目标配置中，切换到输入转换 > 模板模式，使用以下模板示例（根据你的实际字段调整）：

{
  "eventType": "UserCreated",
  "userId": "$.dynamodb.NewImage.userId.S",
  "email": "$.dynamodb.NewImage.email.S",
  "roles": [
    #foreach($roleEntry in $.dynamodb.NewImage.roles.L)
      "$roleEntry.S"#if($foreach.hasNext),#end
    #end
  ]
}

#foreach循环会遍历roles.L下的所有元素，提取每个元素的S值（DDB字符串类型的存储值）
#if($foreach.hasNext)用来处理数组最后一个元素的逗号，确保输出是合法JSON

如果roles字段可能为空或不存在，可以添加判断避免模板报错：

{
  "eventType": "UserCreated",
  "userId": "$.dynamodb.NewImage.userId.S",
  "email": "$.dynamodb.NewImage.email.S",
  "roles": [
    #if($.dynamodb.NewImage.roles && $.dynamodb.NewImage.roles.L)
      #foreach($roleEntry in $.dynamodb.NewImage.roles.L)
        "$roleEntry.S"#if($foreach.hasNext),#end
      #end
    #end
  ]
}

2. 尝试JSONPath数组通配符

如果更倾向于用JSONPath映射，试试使用数组通配符[*]来提取所有元素的S值，输入映射配置如下：

{
  "eventType": "UserCreated",
  "userId": "$.dynamodb.NewImage.userId.S",
  "email": "$.dynamodb.NewImage.email.S",
  "roles": "$.dynamodb.NewImage.roles.L[*].S"
}

注意：Pipes的JSONPath基于Jayway实现，部分复杂语法可能不支持，若之前报错，检查是否存在语法错误（比如路径中的引号、层级是否正确），可以用Pipes的测试事件功能验证映射结果。