使用Lambda Web Adapter运行Go应用遇INIT_REPORT Runtime.ExitError求助

你遇到的INIT_REPORT Runtime.ExitError错误，根源在于Lambda的自定义运行时（包括搭配Lambda Web Adapter的场景）要求初始化阶段启动的进程必须持续存活，以监听后续的Invoke调用请求。而你的Go程序是一次性执行任务后直接退出，导致Lambda认为初始化失败，触发重试逻辑，进而出现两次运行的情况。

针对定时触发单次任务的需求，提供两种可行方案：

方案一：修改Go程序适配Lambda自定义运行时协议 #

直接让程序遵循Lambda自定义运行时的API规范，持续监听Invoke事件，任务仅在收到事件时执行，执行完成后保持进程存活。

调整后的Dockerfile #

FROM public.ecr.aws/lambda/provided:al2
COPY main /main
ENTRYPOINT [ "/main" ]

Go程序示例逻辑 #

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"os"
)

func main() {
	runtimeAPI := os.Getenv("AWS_LAMBDA_RUNTIME_API")
	if runtimeAPI == "" {
		fmt.Println("AWS_LAMBDA_RUNTIME_API环境变量未设置")
		os.Exit(1)
	}

	// 持续监听Lambda调用请求
	for {
		// 获取下一个调用事件
		invocationResp, err := http.Get(fmt.Sprintf("http://%s/2018-06-01/runtime/invocation/next", runtimeAPI))
		if err != nil {
			fmt.Printf("获取调用事件失败: %v\n", err)
			os.Exit(1)
		}
		defer invocationResp.Body.Close()

		invocationID := invocationResp.Header.Get("Lambda-Runtime-Aws-Request-Id")
		// 读取事件内容（若无需使用事件数据可忽略此步骤）
		_, err = io.ReadAll(invocationResp.Body)
		if err != nil {
			fmt.Printf("读取事件内容失败: %v\n", err)
			sendErrorResponse(runtimeAPI, invocationID, err)
			continue
		}

		// 执行你的定时任务逻辑
		fmt.Println("开始执行任务...")
		// 替换为你的实际任务代码
		taskResult := "任务执行完成"

		// 向Lambda发送成功响应
		sendSuccessResponse(runtimeAPI, invocationID, taskResult)
	}
}

func sendSuccessResponse(runtimeAPI, invocationID, result string) {
	respBody, _ := json.Marshal(map[string]string{"result": result})
	_, err := http.Post(fmt.Sprintf("http://%s/2018-06-01/runtime/invocation/%s/response", runtimeAPI, invocationID),
		"application/json", bytes.NewBuffer(respBody))
	if err != nil {
		fmt.Printf("发送成功响应失败: %v\n", err)
	}
}

func sendErrorResponse(runtimeAPI, invocationID string, err error) {
	errorResp := map[string]interface{}{
		"errorType":    "TaskExecutionError",
		"errorMessage": err.Error(),
	}
	respBody, _ := json.Marshal(errorResp)
	_, err = http.Post(fmt.Sprintf("http://%s/2018-06-01/runtime/invocation/%s/error", runtimeAPI, invocationID),
		"application/json", bytes.NewBuffer(respBody))
	if err != nil {
		fmt.Printf("发送错误响应失败: %v\n", err)
	}
}

方案二：将Go程序改为Web服务配合Lambda Web Adapter #

把程序改造为HTTP服务，通过Lambda Web Adapter将Lambda的Invoke请求转换为HTTP请求转发给程序，程序处理请求后返回响应并保持服务运行。

调整后的Dockerfile #

FROM public.ecr.aws/lambda/provided:al2
COPY --from=public.ecr.aws/awsguru/aws-lambda-adapter:0.7.1 /lambda-adapter /opt/extensions/lambda-adapter
COPY main /main
# 指定Web Adapter转发请求的端口
ENV PORT=8080
ENTRYPOINT [ "/main" ]

Go程序示例逻辑 #

package main

import (
	"fmt"
	"net/http"
)

func main() {
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		// 执行你的定时任务逻辑
		fmt.Println("开始执行任务...")
		// 替换为你的实际任务代码
		taskResult := "任务执行完成"

		w.WriteHeader(http.StatusOK)
		fmt.Fprintf(w, taskResult)
	})

	port := "8080"
	fmt.Printf("服务启动，监听端口:%s\n", port)
	err := http.ListenAndServe(":"+port, nil)
	if err != nil {
		fmt.Printf("服务启动失败: %v\n", err)
	}
}

• 调整Lambda函数超时时间为略长于任务执行时间（比如15秒），避免任务未完成被强制终止
• 根据程序资源需求调整函数的内存、CPU配置
• 确认定时触发器的调度表达式设置正确，确保按预期触发任务

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