通过 Golang 中的步骤函数调用 AWS lambda 函数

当前位置： > > > > 通过 Golang 中的步骤函数调用 AWS lambda 函数

来源：stackoverflow
2024-04-20 18:15:36
0浏览
收藏

从现在开始，我们要努力学习啦！今天我给大家带来《通过 Golang 中的步骤函数调用 AWS lambda 函数》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

问题内容

我有一个 aws 步骤函数，它调用用 golang 编写的 lambda 函数。由于某种原因，lambda 函数似乎无法读取步骤函数的输入。

lambda 函数 –

package main

import (
    "fmt"

    "github.com/aws/aws-lambda-go/lambda"
)

type inevent struct {
    name string `json:"name"`
}

type outevent struct {
    greeting string `json:"greeting"`
}

func handlerequest(name inevent) (outevent, error) {
    var result outevent
    result.greeting = fmt.sprintf("hello %s!", name.name)
    return result, nil
}

func main() {
    lambda.start(handlerequest)
}

阶跃函数 –

{
  "comment": "a hello world example of the amazon states language using pass states",
  "startat": "invoke lambda function",
  "states": {
    "invoke lambda function": {
      "type": "task",
      "resource": "arn:aws:states:::lambda:invoke",
      "parameters": {
        "functionname": "arn:aws:lambda:us-west-1:301438421794:function:sf1_1:$latest",
        "payload": {
          "input.$": "$"
        }
      },
      "end": true
    }
  }
}

阶跃函数的输入 –

{
  "name": "abcde"
}

阶跃函数的输出 –

{
  "ExecutedVersion": "$LATEST",
  "Payload": {
    "greeting": "Hello !"
  },
  "SdkHttpMetadata": {
    "AllHttpHeaders": {
      "X-Amz-Executed-Version": [
        "$LATEST"
      ],
      "x-amzn-Remapped-Content-Length": [
        "0"
      ],
      "Connection": [
        "keep-alive"
      ],
      "x-amzn-RequestId": [
        "5f297331-8b1a-49a0-9ad9-17a78ec1cfd0"
      ],
      "Content-Length": [
        "22"
      ],
      "Date": [
        "Fri, 25 Dec 2020 19:58:20 GMT"
      ],
      "X-Amzn-Trace-Id": [
        "root=1-5fe6445c-5cb6860d2559230940506a2f;sampled=0"
      ],
      "Content-Type": [
        "application/json"
      ]
    },
    "HttpHeaders": {
      "Connection": "keep-alive",
      "Content-Length": "22",
      "Content-Type": "application/json",
      "Date": "Fri, 25 Dec 2020 19:58:20 GMT",
      "X-Amz-Executed-Version": "$LATEST",
      "x-amzn-Remapped-Content-Length": "0",
      "x-amzn-RequestId": "5f297331-8b1a-49a0-9ad9-17a78ec1cfd0",
      "X-Amzn-Trace-Id": "root=1-5fe6445c-5cb6860d2559230940506a2f;sampled=0"
    },
    "HttpStatusCode": 200
  },
  "SdkResponseMetadata": {
    "RequestId": "5f297331-8b1a-49a0-9ad9-17a78ec1cfd0"
  },
  "StatusCode": 200
}

我希望 output.payload.greeting 为“hello abcde!”但 output.payload.greeting 是“你好！”

这里出了什么问题？为什么 lambda 函数中的 name 变量无法正确存储输入？为什么 lambda 函数中“abcde”会变成空字符串？

当我直接在 lambda 控制台上测试 lambda 函数而不使用步骤函数时，一切正常。

解决方案

分享代码和示例时要小心，因为您的帐户 id 也会被暴露

下面是包含 golang 代码的工作状态机

{
    "comment": "a hello world example of the amazon states language using pass states",
    "startat": "invoke lambda function",
    "states": {
        "invoke lambda function": {
        "type": "task",
        "resource": "arn:aws:states:::lambda:invoke",
        "parameters": {
            "functionname": "arn:aws:lambda:us-east-1:301438421794:function:testfunction",
            "payload": {
            "name.$": "$.name"
            }
        },
        "resultpath": "$.lambdaoutput",
        "end": true
        }
    }
    }

产生如下输出：

{
    "name": "suresh",
    "lambdaoutput": {
        "executedversion": "$latest",
        "payload": {
        "greeting": "hello suresh!"
        },
        "sdkhttpmetadata": {
    ....
    }

您可以通过像这样修改来进一步分割输出

"outputpath": "$.lambdaoutput.payload",

这将为您提供准确的输出

{
    "greeting": "hello suresh!"
    }

看看 。这是我可以推荐的开始使用步进函数的最佳资源。

为了处理函数之间的数据，请保持 方便。对于处理输入和输出 也非常有用。

状态机定义中的 payload 部分正在调整传递给 lambda 的输入：

"payload": {
    "input.$": "$"
}

所以 lambda 的实际输入将是：

{ 
    input: 
        { 
            name: 'abcde' 
    } 
}

因此，您需要在 golang 代码中考虑这一点，或者更改状态机定义中的 payload 部分。

理论要掌握，实操不能落！以上关于《通过 Golang 中的步骤函数调用 AWS lambda 函数》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注公众号吧！