Golang中如何实现AWS Lambda之间的相互调用

Golang中如何实现AWS Lambda之间的相互调用 谁能帮我提供一段Go语言代码片段，用于调用另一个Lambda函数？

2 回复

你只需要触发事件来调用它。有多种方法可以实现：

https://docs.aws.amazon.com/lambda/latest/dg/invoking-lambda-function.html

更多关于Golang中如何实现AWS Lambda之间的相互调用的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html


以下是一个使用Go语言在AWS Lambda中调用另一个Lambda函数的代码示例：

package main

import (
    "context"
    "encoding/json"
    "fmt"
    
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/lambda"
    "github.com/aws/aws-sdk-go-v2/service/lambda/types"
)

type MyEvent struct {
    Name string `json:"name"`
}

type Response struct {
    StatusCode int    `json:"statusCode"`
    Body       string `json:"body"`
}

func handler(ctx context.Context, event MyEvent) (Response, error) {
    // 加载AWS配置
    cfg, err := config.LoadDefaultConfig(ctx)
    if err != nil {
        return Response{
            StatusCode: 500,
            Body:       fmt.Sprintf("Error loading config: %v", err),
        }, err
    }

    // 创建Lambda客户端
    lambdaClient := lambda.NewFromConfig(cfg)
    
    // 准备调用目标Lambda函数的数据
    payload, err := json.Marshal(map[string]interface{}{
        "key1": "value1",
        "key2": "value2",
        "key3": "value3",
    })
    if err != nil {
        return Response{
            StatusCode: 500,
            Body:       fmt.Sprintf("Error marshaling payload: %v", err),
        }, err
    }

    // 调用目标Lambda函数
    invokeOutput, err := lambdaClient.Invoke(ctx, &lambda.InvokeInput{
        FunctionName:   aws.String("目标Lambda函数名称"),
        InvocationType: types.InvocationTypeRequestResponse,
        Payload:        payload,
    })
    if err != nil {
        return Response{
            StatusCode: 500,
            Body:       fmt.Sprintf("Error invoking Lambda: %v", err),
        }, err
    }

    // 处理响应
    var responseData map[string]interface{}
    if err := json.Unmarshal(invokeOutput.Payload, &responseData); err != nil {
        return Response{
            StatusCode: 500,
            Body:       fmt.Sprintf("Error unmarshaling response: %v", err),
        }, err
    }

    return Response{
        StatusCode: 200,
        Body:       fmt.Sprintf("Successfully invoked Lambda: %v", responseData),
    }, nil
}

此代码需要以下依赖项：

go mod init lambda-invoker
go get github.com/aws/aws-sdk-go-v2
go get github.com/aws/aws-sdk-go-v2/config
go get github.com/aws/aws-sdk-go-v2/service/lambda

代码说明：

  1. 使用AWS SDK for Go v2创建Lambda客户端
  2. 准备要传递给目标Lambda函数的payload数据
  3. 使用Invoke方法同步调用目标Lambda函数
  4. 处理并返回目标Lambda函数的响应

注意：确保执行此代码的Lambda函数具有调用其他Lambda函数的IAM权限，并将"目标Lambda函数名称"替换为实际的目标函数名称。

回到顶部