SQS-Step Functions管道启动失败：ResultPath配置异常求助

异常原因 #

你的状态机启动时输入是数组格式（如异常信息所示：[{"messageId":"xyz",...}]），但ListExecutions状态中使用"ResultPath": "$.ExecutionDetails"尝试给数组添加命名属性。Step Functions不允许直接在数组对象上设置键值对，因此抛出States.ReferencePathConflict错误。

修复步骤 #

1. 转换输入格式为对象 #

新增一个初始Pass状态，将输入数组转换为对象结构，把原数组内容存入指定字段，确保后续状态能正常使用ResultPath添加属性：

"Initialize Input": {
  "Type": "Pass",
  "Next": "ListExecutions",
  "Parameters": {
    "SQSInput.$": "$[0]"
  }
}

同时将状态机的StartAt改为"Initialize Input"。

2. 修复ReceiptHandle拼写错误 #

ReceiveMessage状态中ReceiptHandle的取值路径拼写错误，将：

"ReceiptHandle.$": "$.Messages[0].ReceiptHand"

修正为：

"ReceiptHandle.$": "$.Messages[0].ReceiptHandle"

3. 调整并发检查逻辑（可选） #

原Check Status状态仅当运行中执行数等于1时才继续处理，这可能不符合"逐个处理"的需求。建议改为当无运行中执行时才启动消息处理：

"Check Status": {
  "Type": "Choice",
  "Choices": [
    {
      "Variable": "$.ExecutionDetails.runningExecutionsCount",
      "NumericEquals": 0,
      "Next": "ReceiveMessage"
    }
  ],
  "Default": "Pass"
}

完整修复后的状态机定义 #

{
  "StartAt": "Initialize Input",
  "States": {
    "Initialize Input": {
      "Type": "Pass",
      "Next": "ListExecutions",
      "Parameters": {
        "SQSInput.$": "$[0]"
      }
    },
    "ListExecutions": {
      "Type": "Task",
      "Next": "Check Status",
      "Parameters": {
        "StateMachineArn.$": "$$.StateMachine.Id",
        "StatusFilter": "RUNNING"
      },
      "Resource": "arn:aws:states:::aws-sdk:sfn:listExecutions",
      "ResultSelector": {
        "StateMachineArn.$": "$$.StateMachine.Id",
        "uuid.$": "States.UUID()",
        "runningExecutionsCount.$": "States.ArrayLength($.Executions)"
      },
      "ResultPath": "$.ExecutionDetails"
    },
    "Check Status": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.ExecutionDetails.runningExecutionsCount",
          "NumericEquals": 0,
          "Next": "ReceiveMessage"
        }
      ],
      "Default": "Pass"
    },
    "ReceiveMessage": {
      "Type": "Task",
      "Next": "Dummy Processing",
      "Parameters": {
        "MaxNumberOfMessages": 1,
        "QueueUrl": "https://sqs.us-east-1.amazonaws.com/xxx/test-sqs.fifo"
      },
      "Resource": "arn:aws:states:::aws-sdk:sqs:receiveMessage",
      "ResultSelector": {
        "body.$": "States.StringToJson($.Messages[0].Body)",
        "ReceiptHandle.$": "$.Messages[0].ReceiptHandle"
      }
    },
    "Pass": {
      "Type": "Pass",
      "End": true
    },
    "Dummy Processing": {
      "Type": "Pass",
      "Next": "DeleteMessage"
    },
    "DeleteMessage": {
      "Type": "Task",
      "Parameters": {
        "QueueUrl": "https://sqs.us-east-1.amazonaws.com/xxx/test-sqs.fifo",
        "ReceiptHandle.$": "$.ReceiptHandle"
      },
      "Resource": "arn:aws:states:::aws-sdk:sqs:deleteMessage",
      "Next": "GetQueueAttributes"
    },
    "GetQueueAttributes": {
      "Type": "Task",
      "Parameters": {
        "AttributeNames": [
          "ApproximateNumberOfMessages"
        ],
        "QueueUrl": "https://sqs.us-east-1.amazonaws.com/xxx/test-sqs.fifo"
      },
      "Resource": "arn:aws:states:::aws-sdk:sqs:getQueueAttributes",
      "Next": "Choice"
    },
    "Choice": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.Attributes.ApproximateNumberOfMessages",
          "StringEquals": "0",
          "Next": "Done"
        }
      ],
      "Default": "ReceiveMessage"
    },
    "Done": {
      "Type": "Pass",
      "End": true
    }
  }
}

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