使用AWS CDK EcsRunTask创建Fargate任务：参数无法在Worker中解析

在使用AWS CDK的EcsRunTask创建Fargate任务时，尝试在containerOverrides的command中传入$.x、$.y这类Step Functions状态机输入参数路径，但这些参数无法在Fargate Worker中被正确解析，最终以原始字符串形式传递。

代码示例：

const vpc = ec2.Vpc.fromLookup(this, 'Vpc', {
  isDefault: true,
});

const cluster = new ecs.Cluster(this, 'FargateCluster', { vpc });

const taskDefinition = new ecs.TaskDefinition(this, 'TD', {
  memoryMiB: '512',
  cpu: '256',
  compatibility: ecs.Compatibility.FARGATE,
});

const containerDefinition = taskDefinition.addContainer('TheContainer', {
  image: ecs.ContainerImage.fromRegistry('foo/bar'),
  memoryLimitMiB: 256,
});

const riTask = new tasks.EcsRunTask(this, 'The task', {
      integrationPattern: IntegrationPattern.RUN_JOB,
      cluster: cluster,
      taskDefinition: taskDefinition,
      containerOverrides: [{
        containerDefinition: containerDefinition,
        command: ["/app/appName", "$.x", "$.y", "$.z"],
      }],
      launchTarget: new tasks.EcsFargateLaunchTarget(),
    });

直接在command数组中写$.x这类字符串，Step Functions不会自动将其解析为状态机输入的路径参数。需要使用CDK提供的JsonPath工具来引用这些参数，让Step Functions在执行时完成值的替换。

修改后的代码：

// 先导入JsonPath工具
import { JsonPath } from 'aws-cdk-lib/aws-stepfunctions';

// ... 其余代码保持不变

const riTask = new tasks.EcsRunTask(this, 'The task', {
      integrationPattern: IntegrationPattern.RUN_JOB,
      cluster: cluster,
      taskDefinition: taskDefinition,
      containerOverrides: [{
        containerDefinition: containerDefinition,
        command: [
          "/app/appName",
          JsonPath.stringAt('$.x'),
          JsonPath.stringAt('$.y'),
          JsonPath.stringAt('$.z')
        ],
      }],
      launchTarget: new tasks.EcsFargateLaunchTarget(),
    });

关键说明： #

• JsonPath.stringAt()方法会将Step Functions输入中指定路径的内容以字符串形式注入到命令参数里。
• 如果参数是数字类型，可改用JsonPath.numberAt()；若无需指定类型，用JsonPath.valueAt()即可。
• 配置后，Step Functions执行EcsRunTask步骤时，会自动把$.x、$.y、$.z替换为状态机输入中的实际值，传递给Fargate容器。

内容的提问来源于stack exchange，提问作者Sanyukta Agrawal