使用AWS CDK v2.147.0时，为何找不到Step Functions的DynamoDB Query任务？

问题根源 #

你的aws-cdk-lib v2.147.0版本里，aws-stepfunctions-tasks模块确实没封装DynamoDB Query的L2构造（就是那种像DynamoGetItem一样开箱即用的类），官方文档只列CRUD操作是因为这些是较早做了封装的常用操作，Query属于需要手动用L1构造实现的功能，不是你漏了配置。

两种解决办法 #

1. 用L1构造AwsSdkCall直接调用Query API #

这是当前版本最靠谱的办法，通过Step Functions的AWS SDK集成功能，直接指定调用DynamoDB的Query接口。代码示例：

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

const app = new cdk.App();
const stack = new cdk.Stack(app, 'DynamoQueryStack');

// 你的DynamoDB表（假设已定义）
const targetTable = new dynamodb.Table(stack, 'MyTable', {
  partitionKey: { name: 'PK', type: dynamodb.AttributeType.STRING },
  sortKey: { name: 'SK', type: dynamodb.AttributeType.STRING },
});

// 定义Query任务
const queryTask = new tasks.AwsSdkCall(stack, 'RunDynamoQuery', {
  service: 'DynamoDB',
  action: 'query',
  parameters: {
    TableName: targetTable.tableName,
    KeyConditionExpression: 'PK = :pkValue',
    ExpressionAttributeValues: {
      ':pkValue': { S: sfn.JsonPath.stringAt('$.inputPk') }, // 从状态机输入取Partition Key值
    },
    // 按需加其他参数，比如ProjectionExpression只返回需要的字段
  },
  iamResources: [targetTable.tableArn],
  iamAction: 'dynamodb:Query',
});

// 创建状态机
const stateMachine = new sfn.StateMachine(stack, 'QueryStateMachine', {
  definition: queryTask,
});

2. 升级CDK版本到v2.150.0+ #

从v2.150.0开始，aws-stepfunctions-tasks新增了DynamoQuery的L2封装，升级后就能用更简洁的写法：

// 升级后的L2写法
const queryTask = new tasks.DynamoQuery(stack, 'RunDynamoQuery', {
  table: targetTable,
  keyConditionExpression: tasks.DynamoConditionExpression.key('PK').eq(sfn.JsonPath.stringAt('$.inputPk')),
  // 可配置投影字段、分页等选项
});

注意事项 #

• 不管用哪种方式，都要保证Step Functions的执行角色有dynamodb:Query权限，L1方案通过iamAction和iamResources手动指定，L2方案会自动生成权限。
• Query的KeyConditionExpression必须包含Partition Key的等值条件，这是DynamoDB的硬性要求，和你在控制台配置的逻辑一致。

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