AWS CDK配置EventBridge Pipes无法触发Express状态机执行

你的问题出在EventBridge Pipe的目标参数未正确配置。通过控制台创建Pipe时，AWS会自动填充Step Functions目标所需的默认参数，但使用CDK的CfnPipe时需要手动指定这些参数，否则Pipe无法正确触发状态机执行。

具体修复步骤 #

1. 补充Pipe的目标参数配置 #

修改CfnPipe定义，添加targetParameters，明确指定Step Functions的执行参数：

const pipe = new CfnPipe(this, 'Pipe', {
    roleArn: pipeRole.roleArn,
    source: queue.queueArn,
    target: stateMachine.stateMachineArn,
    // 新增目标参数配置
    targetParameters: {
        stepFunctionsStartExecutionParameters: {
            // 根据你的SQS消息结构调整输入映射
            // 如果SQS消息体是JSON格式，使用$.Body获取消息内容
            input: "$.Body"
        }
    },
    // 配置SQS源参数，确保消息能被正确读取
    sourceParameters: {
        sqsQueueParameters: {
            batchSize: 1,
            maximumBatchingWindowInSeconds: 0
        }
    }
});

2. 为Pipe添加日志配置（推荐） #

添加日志配置后，你可以在CloudWatch中看到Pipe的详细错误信息，便于后续排查：

const pipeLogGroup = new LogGroup(this, 'PipeLogGroup', {
    retention: RetentionDays.ONE_WEEK
});

const pipe = new CfnPipe(this, 'Pipe', {
    roleArn: pipeRole.roleArn,
    source: queue.queueArn,
    target: stateMachine.stateMachineArn,
    targetParameters: {
        stepFunctionsStartExecutionParameters: {
            input: "$.Body"
        }
    },
    sourceParameters: {
        sqsQueueParameters: {
            batchSize: 1,
            maximumBatchingWindowInSeconds: 0
        }
    },
    // 新增日志配置
    logConfiguration: {
        cloudWatchLogsLogDestination: {
            logGroupArn: pipeLogGroup.logGroupArn
        },
        level: 'ERROR'
    }
});

关键说明 #

• 当目标是Step Functions Express状态机时，必须通过stepFunctionsStartExecutionParameters指定输入映射，否则Pipe无法正确解析SQS消息并触发执行。
• 控制台创建Pipe时，AWS会默认设置input: "$"（传递整个SQS消息结构），但CDK的CfnPipe不会自动填充这个参数，需要手动添加。
• 配置日志后，若再次出现失败，你可以在Pipe的日志组中查看具体错误原因（比如输入格式不匹配、权限问题等）。

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