amazon-web-services - 将数据传递给步进功能捕获

Question

我在AWS上使用了步进功能。考虑由lambda组成的状态机:

"StartAt": "Metadata",
              "States": {
                    "Metadata": {
                    "Type": "Task",
                    "Resource": "${metadataArn}",
                    "Next": "StoreMetadata",
                    "Retry" : [
                            {
                                "ErrorEquals": [ "States.All" ],
                                "IntervalSeconds": 2,
                                "MaxAttempts": 3
                            }
                    ],
                    "Catch": [
                        {
                            "ErrorEquals": [ "States.All" ],
                            "Next": "ErrorHandler"
                        }
                    ]
                  } ...
                      ...

如何将特定数据传递给“ErrorHandler”。例如，失败的步骤可能是一条数据。我正在使用nodejs，但可以推断到任何运行时。

例如在节点中，我们可能有一个lambda，其中:

module.exports.handler = async input => {
  const ids = JSON.parse(input).ids
  // try to read in data for ids.
  // read fails / throws exception
}

如何让错误处理程序获取ID数组，以便将其标记为失败？如果此“ErrorHandler”是多个步骤的陷阱，我如何知道哪些步骤失败了？

Answer 1

我找到了答案，您可以使用ResultPath传递原始输入以及错误。我想我会将步骤作为属性包含在所有输入中，以便我知道哪个步骤失败了。有关说明，请参见docs。从本质上来说，您只需添加ResultPath属性即可，如下所示:

"Catch": [
  {
    "ErrorEquals": [ "States.All" ],
    "Next": "ErrorHandler"
    "ResultPath": "$.error"
  }
]