如何基于StepFunction序列化输出的指定字段创建EventBridge规则？

问题根源 #

EventBridge接收的Step Functions状态变更事件中，detail.output是JSON序列化后的字符串，而非结构化JSON对象，因此直接用事件模式按对象字段匹配fraudStatus会失效。

可行解决方案 #

方案1：用EventBridge Pipes解析JSON后过滤 #

EventBridge Pipes支持在事件流转过程中转换数据，可先解析字符串为结构化JSON再做匹配：

• 创建EventBridge Pipe，源选择Step Functions的状态变更事件（关联对应事件总线，先匹配所有成功执行的事件）
• 在Pipe的转换阶段，使用Input Transformer或Lambda函数，将detail.output的字符串解析为JSON对象
• 在Pipe的过滤阶段，添加条件匹配解析后的fraudStatus字段值为"RELEASE"
• 配置Pipe的目标为你需要触发的资源（如Lambda、SQS等）

方案2：用Lambda作为中间层实现精准过滤 #

通过Lambda先解析字符串再判断，替代EventBridge直接匹配：

• 创建Lambda函数，接收EventBridge传入的Step Function事件
• 在函数内将detail.output字符串解析为JSON对象，检查fraudStatus是否等于"RELEASE"
• 若符合条件，直接执行业务逻辑或转发事件到目标资源
• 创建EventBridge规则，将所有Step Functions成功执行的事件发送到该Lambda

方案3：在Step Function中主动发送结构化事件 #

绕过Step Functions自动生成的状态变更事件，直接发送自定义结构化事件到EventBridge：

• 在Step Function的最后一步添加Task状态，调用EventBridge的PutEvents API
• 构造自定义事件，将fraudStatus等需要匹配的字段作为detail的结构化属性
• 创建EventBridge规则，直接匹配自定义事件中的fraudStatus: "RELEASE"条件

临时方案：用字符串包含匹配（不推荐用于复杂场景） #

如果输出格式固定，可利用EventBridge的字符串contains匹配规则临时解决：
修改事件模式为：

{
  "source": ["aws.states"],
  "detail-type": ["Step Functions Execution Status Change"],
  "detail": {
    "status": ["SUCCEEDED"],
    "output": [{"contains": "\"fraudStatus\":\"RELEASE\""}]
  }
}

注意：该方法存在误匹配风险（如其他字段值包含相同字符串时），仅适合格式完全固定的场景。

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