如何格式化并个性化AWS SNS消息？解决Glue Job参数读取失败问题

错误原因 #

你直接在SNS状态的消息字符串中嵌入$.JobName这类状态路径是无效的——Step Functions不会自动解析普通字符串里的路径表达式，只会把它当作纯文本处理。要正确引用工作流中的参数，需要用Step Functions支持的字符串插值语法或内置函数拼接。

方案1：使用字符串插值（推荐，适用于新版Step Functions） #

在SNS状态的Message字段中，用${}包裹状态路径，Step Functions会自动解析并替换为对应的值：

{
  "Type": "SNS",
  "Resource": "arn:aws:sns:你的区域:你的账号ID:你的SNS主题",
  "Parameters": {
    "Message": "Job ${$.JobName} ${$.JobRunState}. Run id: ${$.Id}",
    "Subject": "Glue Job状态通知"
  },
  "End": true
}

注意：确保你的工作流执行到SNS状态时，上下文数据中确实存在JobName、JobRunState、Id这些字段——如果是Glue Job执行后的输出，要检查Glue状态的ResultPath设置，保证这些参数被传递到后续步骤。

方案2：用Pass状态预处理消息（兼容旧版Step Functions） #

如果字符串插值不生效，可以先通过Pass状态用States.Format内置函数拼接好消息，再传递给SNS：

第一步：添加Pass状态组装消息 #

{
  "Type": "Pass",
  "Parameters": {
    "Message.$": "States.Format('Job {} {}. Run id: {}', $.JobName, $.JobRunState, $.Id)"
  },
  "Next": "Send SNS Notification"
}

第二步：在SNS状态中引用预处理后的消息 #

{
  "Type": "SNS",
  "Resource": "arn:aws:sns:你的区域:你的账号ID:你的SNS主题",
  "Parameters": {
    "Message.$": "$.Message",
    "Subject": "Glue Job状态通知"
  },
  "End": true
}

States.Format函数会按照占位符{}的顺序，依次替换为后面的参数值，能可靠解析状态路径。

关键检查点 #

• 确认Glue Job执行完成后，输出数据中包含JobName、JobRunState、Id字段——可以在Step Functions控制台的执行历史中查看上下文数据，验证参数是否存在。
• 动态引用参数时，字段名必须加. $后缀（如Message.$），Step Functions才会识别为路径表达式，而非静态字符串。

内容的提问来源于stack exchange，提问作者Simón López