如何通过CDK在AWS Step Functions DistributedMap中动态获取S3 Bucket和Key？

云原生阿岚

2026-6-27

问题描述

能否通过AWS CDK从状态机输入中动态获取S3的Bucket和Key？在AWS控制台中可以配置ItemReader的Key.$参数来引用输入路径$.key，但使用CDK的S3JsonItemReader做相同配置时似乎无法生效。

控制台配置示例：

"ItemReader": {
        "Resource": "arn:aws:states:::s3:getObject",
        "ReaderConfig": {
          "InputType": "JSON"
        },
        "Parameters": {
          "Bucket": "my-bucket",
          "Key.$": "$.key"
        }
      }

CDK错误代码示例：

const map = new sfn.DistributedMap(this, 'Parse the document', {
      itemReader: new sfn.S3JsonItemReader({
        bucket: myBucket,
        key: '$.key',
      }),
    })

解决方案

可以实现动态获取，问题出在S3JsonItemReader的key参数仅支持静态字符串，无法识别路径引用语法。要配置动态Key，需要通过自定义参数的方式实现，有两种常用方法：

方法1：使用`ItemReader.fromS3GetObject`直接构造

直接通过底层的S3 GetObject资源构造ItemReader，显式配置动态参数：

const map = new sfn.DistributedMap(this, 'Parse the document', {
  itemReader: sfn.ItemReader.fromS3GetObject({
    bucket: myBucket,
    // 配置动态Key引用
    parameters: {
      'Key.$': '$.key'
    },
    readerConfig: {
      inputType: sfn.InputType.JSON
    }
  })
});

方法2：扩展`S3JsonItemReader`并添加自定义参数

如果想继续使用S3JsonItemReader，可以通过addParameters方法覆盖默认参数，添加动态Key配置：

// 创建基础的S3JsonItemReader，不指定静态key
const itemReader = new sfn.S3JsonItemReader({
  bucket: myBucket
});

// 添加动态Key参数
itemReader.addParameters({
  'Key.$': '$.key'
});

const map = new sfn.DistributedMap(this, 'Parse the document', {
  itemReader: itemReader
});