Step Functions调用SNS使用States.Format报错的问题咨询

你遇到的问题是Step Functions的SNS集成对参数解析的规则限制导致的：带. $后缀的字段（比如Message.$）只能直接使用JSONPath表达式，无法直接嵌套States.Format这类内置函数，这就是为什么你会收到"必须是有效的JSONPath或内置函数调用"的错误——SNS集成在解析Message.$时，会把States.Format(...)当成了JSONPath来处理，自然不识别。

正确的两种实现方式 #

方式1：通过Parameters.$整体调用内置函数

把整个参数对象用States.Format生成，通过Parameters.$触发内置函数执行，再将结果传给SNS：

"HandleError": {
    "Type": "Task",
    "Resource": "arn:aws:states:::sns:publish",
    "Parameters.$": "States.Format('{\"TopicArn\": \"arn:aws:sns:region:accountid:topic\", \"Message\": \"Message: {}\"}', $.message)"
}

注意：这里要转义JSON字符串里的双引号，避免语法错误。

方式2：先通过Pass状态预处理参数（更易读）

先新增一个Pass状态，用内置函数处理好消息内容，再把完整的参数对象传给SNS任务：

"PrepareErrorMessage": {
    "Type": "Pass",
    "Parameters": {
        "TopicArn": "arn:aws:sns:region:accountid:topic",
        "Message.$": "States.Format('Message: {}', $.message)"
    },
    "Next": "HandleError"
},
"HandleError": {
    "Type": "Task",
    "Resource": "arn:aws:states:::sns:publish",
    "Parameters.$": "$"
}

这种方式逻辑更清晰，也不需要处理复杂的字符串转义。

补充说明 #

Step Functions的服务集成（比如SNS、SQS等）对参数的解析逻辑是：

• 如果字段名带. $，则直接按JSONPath解析取值，不会执行内置函数
• 只有当Parameters本身用. $（即Parameters.$）时，才会先执行内置函数，再将结果作为参数传给集成服务

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