json - 使用 EventBridge 输入转换器时如何从状态机输出中提取属性

Question

我无法使用 EventBridge 服务将 AWS 状态机返回的值之一作为输入传递给 Lambda。
我在 AWS Step Functions 中创建了一个状态机来对我们域中的特定问题进行建模。状态机完成后，我想从我的一个 Lambda 内部执行另一个操作。为了实现这一点，我使用 EventBridge 创建了一个新规则:每当状态机完成时，它都会使用特定的 Json 输入触发我的 lambda。
我的问题是如何从状态机输出中提取属性并将它们作为 lambda 输入的属性传递。
说我的状态机返回这个:

{
    "usefulObject":{
        "usefulProperty":"value"
    },
    "anotherProperty":"anotherValue"
}

我想在我的 lambda 中接收以下有效负载:

{
    "property":"value"
}

最初，我认为我可以使用 EventBridge 规则上的“输入转换”选项来执行此操作，例如:

输入转换器路径:

{"propertyValue":"$.usefulObject.usefulProperty"}

InputTransformer 模板:

{"property":<propertyValue>}

然而，在测试过程中，我意识到事件负载包含的数据比我的状态机输出多得多。实际上，状态机输出被包裹在这个“事件容器”对象中，如下所示:

{
    "version": "0",
    "id": "...",
    "detail-type": "Step Functions Execution Status Change",
    "source": "aws.states",
    "account": "...",
    "time": "2020-11-10T13:59:57Z",
    "region": "us-east-1",
    "resources": [
        "...myStateMachineArn..."
    ],
    "detail": {
        "executionArn": "...myStateMachineExecutionArn...",
        "stateMachineArn": "...myStateMachineArn...",
        "name": "ff72036a-2917-c657-80e7-2589b7b76d59",
        "status": "SUCCEEDED",
        "startDate": 1605016794597,
        "stopDate": 1605016797936,
        "input": "{\n  \"usefulObject\":{\n    \"usefulProperty\": \"value\"\n  },\n  \"anotherProperty\": \"anotherValue\"\n}",
        "inputDetails": {
            "included": true
        },
        "output": "{\n  \"usefulObject\":{\n    \"usefulProperty\": \"value\"\n  },\n  \"anotherProperty\": \"anotherValue\"\n}",
        "outputDetails": {
            "included": true
        }
    }
}

正如你所看到的，在实际的事件负载中，我的状态机数据作为字符串化的 Json 值存储在 output 中。节点。如果我然后将我的输入转换路径更改为:

{"propertyValue":"$.detail.output.usefulObject.usefulProperty"}

我得到 property 的空结果在转换后的输入中。事实证明，JsonPath 无法将字符串化的值作为 Json 有效负载的一部分进行遍历，因此搜索将失败。
我如何提取 usefulProperty从事件负载中的 Json 字符串中取出值，以便我可以将它传递给我的 lambda 函数？有没有办法使用我缺少的纯 JsonPath 来做到这一点？也许有一种方法可以将 AWS 配置为不将有效负载转换为字符串，而仅将其作为整个事件有效负载的一部分？还有其他选择吗？

Answer 1

有几件事你可以尝试防止你的输入和输出被解释器字符串化:

而不是输入:

{"propertyValue":"$.usefulObject.usefulProperty"}

尝试

{"propertyValue.$":"$.usefulObject.usefulProperty"}

或者

{"propertyValue": $.usefulObject.usefulProperty}

确保您的 lambda 不会返回结果的字符串化版本，即:return JSON.stringify(usefulObject)

如果这些都没有帮助，您可以尝试使用以下命令转换步骤函数模板中的输出字符串:

{
    "propertyValue.$": "States.StringToJson($.detail.output.usefulObject.usefulProperty)"
}

长镜头:确保您没有故意将其转换为字符串，在您的步进函数模板中使用 States.JsonToString某处... :)

根据 https://states-language.net/ 上的文档

尝试从 Lambda 内的事件对象中提取值，然后使用它:

exports.lambdaHandler = async (event) => {
  // parse your input or output string and use it as an object;
  let receivedParams = JSON.parse(event.detail.input);
  let propertyValueObject = {
    propertyValue: receivedParams.usefulObject.usefulProperty,
  };

  // do something in your lambda with propertValueObject 
  // which is equal to: { propertyValue: 'value' }
  console.log(propertyValueObject);
};

let event = {
    "version": "0",
    "id": "...",
    "detail-type": "Step Functions Execution Status Change",
    "source": "aws.states",
    "account": "...",
    "time": "2020-11-10T13:59:57Z",
    "region": "us-east-1",
    "resources": [
        "...myStateMachineArn..."
    ],
    "detail": {
        "executionArn": "...myStateMachineExecutionArn...",
        "stateMachineArn": "...myStateMachineArn...",
        "name": "ff72036a-2917-c657-80e7-2589b7b76d59",
        "status": "SUCCEEDED",
        "startDate": 1605016794597,
        "stopDate": 1605016797936,
        "input": "{\n  \"usefulObject\":{\n    \"usefulProperty\": \"value\"\n  },\n  \"anotherProperty\": \"anotherValue\"\n}",
        "inputDetails": {
            "included": true
        },
        "output": "{\n  \"usefulObject\":{\n    \"usefulProperty\": \"value\"\n  },\n  \"anotherProperty\": \"anotherValue\"\n}",
        "outputDetails": {
            "included": true
        }
    }
}

const lambdaHandler = (event) => {
  // parse your input or output string and use it as an object;
  let receivedParams = JSON.parse(event.detail.input);
  let propertyValueObject = {
    propertyValue: receivedParams.usefulObject.usefulProperty,
  };

  // do something in your lambda with propertValueObject 
  // which is equal to: { propertyValue: 'value' }
  console.log(propertyValueObject);
};

lambdaHandler(event)