如何通过AWS EventBridge输入转换器访问EMR集群stateChangeReason的code与message？

问题核心：EMR作业失败事件里的stateChangeReason是JSON格式的字符串，而非嵌套JSON对象，常规JSONPath无法直接提取其中的code和message字段，导致输入转换器无法生成有效消息。

方法1：使用EventBridge内置函数转换字符串为JSON #

EventBridge输入转换器支持States.StringToJson函数，可将JSON字符串转为对象后提取字段，步骤如下：

1. 在EventBridge规则的输入转换器中，设置输入路径：

   {"reasonStr": "$.detail.stateChangeReason"}
   

2. 设置输入模板（以发送SNS邮件为例）：

   {
     "subject": "EMR作业失败通知",
     "message": "作业失败原因代码：<States.StringToJson($.reasonStr).code>\n详细信息：<States.StringToJson($.reasonStr).message>"
   }
   

   模板中通过States.StringToJson($.reasonStr)将字符串转为JSON对象，再通过.code和.message提取对应字段。

方法2：通过Lambda中转处理事件 #

如果需要更灵活的逻辑（比如异常处理、多字段组合），可以用Lambda作为EventBridge的目标，在代码中解析字符串：

1. 创建Lambda函数（以Python为例）：

   import json
   import boto3
   
   sns_client = boto3.client('sns')
   # 替换为你的SNS主题ARN
   SNS_TOPIC_ARN = "arn:aws:sns:us-east-1:123456789012:emr-failure-alert"
   
   def lambda_handler(event, context):
       # 提取事件中的stateChangeReason字符串
       state_reason_str = event['detail']['stateChangeReason']
       try:
           # 解析为JSON对象
           state_reason = json.loads(state_reason_str)
           code = state_reason.get('code', '未知错误码')
           msg = state_reason.get('message', '无详细错误信息')
       except json.JSONDecodeError:
           code = '解析失败'
           msg = f"无法解析原因字符串：{state_reason_str}"
   
       # 构造并发送邮件
       sns_client.publish(
           TopicArn=SNS_TOPIC_ARN,
           Subject="EMR作业失败告警",
           Message=f"错误码：{code}\n错误详情：{msg}"
       )
       return {"statusCode": 200, "body": "告警已发送"}
   

2. 给Lambda配置权限：允许EventBridge触发该函数，同时允许Lambda调用SNS发布消息。

注意事项 #

• 确保stateChangeReason是合法的JSON字符串，否则States.StringToJson或json.loads会抛出异常；
• 使用输入转换器时，模板语法要严格符合EventBridge的要求，避免语法错误导致消息无法生成；
• Lambda方法需注意权限配置，避免因权限不足导致消息发送失败。

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