AWS CDK Step Function EcsRunTask如何引用输入变量指定任务定义

CDK 完全支持动态传入 ECS 任务定义，不需要预先硬编码固定的任务定义资源，你原配置中"TaskDefinition.$": "$.task"的效果可以通过CDK内置的JsonPath工具实现，最终编译生成的ASL（Amazon States Language）配置和你手写的原生JSON完全一致。

核心实现逻辑 #

Step Functions 所有带.$后缀的动态路径参数，在CDK中都可以通过aws-stepfunctions模块下的JsonPath类对应方法生成。针对你的ECS RunTask同步任务场景，TypeScript CDK代码示例如下：

import * as sfn from 'aws-cdk-lib/aws-stepfunctions';
import * as tasks from 'aws-cdk-lib/aws-stepfunctions-tasks';
import * as ecs from 'aws-cdk-lib/aws-ecs';

// 引用已有ECS集群，不需要提前绑定具体任务定义
const ecsCluster = ecs.Cluster.fromClusterArn(this, 'ImportedCluster', 'my cluster arn');

// 定义ECS运行任务节点
const startTask = new tasks.EcsRunTask(this, 'Start Task', {
  cluster: ecsCluster,
  launchType: tasks.LaunchType.EC2,
  // 对应原配置的.sync同步执行模式，等待任务运行结束再进入下一步
  integrationPattern: sfn.IntegrationPattern.RUN_JOB,
  // 注意：动态指定任务定义时，不要给构造函数传入静态的taskDefinition参数
  // 通过parameters覆写，注入动态路径取值
  parameters: {
    TaskDefinition: sfn.JsonPath.stringAt('$.task'),
  },
});

// 定义后续成功、失败节点
const taskSuccess = new sfn.Succeed(this, 'Task Success');
const taskFailure = new sfn.Fail(this, 'Task Failure');

// 配置流转逻辑
startTask.next(taskSuccess);
startTask.addCatch(taskFailure, {
  errors: [sfn.Errors.ALL],
});

注意事项 #

• 不要同时给EcsRunTask构造函数传入静态taskDefinition实例，否则CDK会自动生成固定的任务定义参数，和你动态传入的配置冲突
• 由于任务定义是动态传入的，CDK不会自动给Step Function执行角色添加对应的ecs:RunTask等权限，你需要手动给角色添加权限，覆盖所有可能被动态传入的任务定义资源的操作权限
• 所有ASL支持的动态路径取值（包括上下文对象、上一步输出、执行输入）都可以通过JsonPath类实现，CDK和原生ASL的动态配置能力完全对齐，不存在功能限制。

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