使用Fuego将Go应用部署到AWS Lambda遇阻，求解决方案

Fuego完全可以在AWS Lambda中用于路由和中间件处理，你的问题通常出在API Gateway请求/响应的转换逻辑不完整，或者未正确注册Fuego路由。以下是修复方案和完整可运行示例：

核心问题排查 #

• 你提供的代码仅初始化了Fuego Server，但未添加任何路由规则，这会导致所有请求返回404
• convertAPIGatewayToHTTPRequest和convertHTTPResponseToAPIGateway函数的实现可能存在遗漏（比如Header处理、路径解析、Body编码等）

完整修复代码 #

package main

import (
	"context"
	"net/http"
	"net/http/httptest"
	"strings"

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

func main() {
	// 1. 初始化Fuego Server并注册路由
	s := fuego.NewServer()
	s.GET("/hello", func(c fuego.Context) error {
		return c.JSON(http.StatusOK, fuego.Map{"message": "Hello from Fuego on Lambda!"})
	})
	s.POST("/echo", func(c fuego.Context) error {
		var body map[string]interface{}
		if err := c.Bind(&body); err != nil {
			return c.JSON(http.StatusBadRequest, fuego.Map{"error": "invalid request body"})
		}
		return c.JSON(http.StatusOK, body)
	})

	// 2. 启动Lambda Handler
	lambda.Start(lambdaHandler(s))
}

// lambdaHandler 将Fuego Server适配为API Gateway Proxy Handler
func lambdaHandler(s *fuego.Server) func(ctx context.Context, req events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {
	return func(ctx context.Context, req events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {
		// 转换API Gateway请求为标准HTTP请求
		httpReq, err := convertAPIGatewayToHTTPRequest(req)
		if err != nil {
			return events.APIGatewayProxyResponse{
				StatusCode: http.StatusInternalServerError,
				Body:       err.Error(),
			}, nil
		}
		httpReq = httpReq.WithContext(ctx)

		// 用Fuego处理请求
		recorder := httptest.NewRecorder()
		s.ServeHTTP(recorder, httpReq)

		// 转换HTTP响应为API Gateway响应
		return convertHTTPResponseToAPIGateway(recorder.Result())
	}
}

// convertAPIGatewayToHTTPRequest 完整实现API Gateway请求到HTTP请求的转换
func convertAPIGatewayToHTTPRequest(req events.APIGatewayProxyRequest) (*http.Request, error) {
	// 处理请求Body
	body := strings.NewReader(req.Body)

	// 创建HTTP请求
	httpReq, err := http.NewRequest(req.HTTPMethod, req.Path, body)
	if err != nil {
		return nil, err
	}

	// 复制Query参数
	q := httpReq.URL.Query()
	for k, v := range req.QueryStringParameters {
		q.Add(k, v)
	}
	httpReq.URL.RawQuery = q.Encode()

	// 复制Headers
	for k, v := range req.Headers {
		httpReq.Header.Add(k, v)
	}
	// 强制设置Content-Type（如果API Gateway未传递）
	if _, ok := httpReq.Header["Content-Type"]; !ok && req.Body != "" {
		httpReq.Header.Add("Content-Type", "application/json")
	}

	return httpReq, nil
}

// convertHTTPResponseToAPIGateway 完整实现HTTP响应到API Gateway响应的转换
func convertHTTPResponseToAPIGateway(resp *http.Response) (events.APIGatewayProxyResponse, error) {
	// 读取响应Body
	bodyBytes := make([]byte, resp.ContentLength)
	if resp.ContentLength > 0 {
		_, err := resp.Body.Read(bodyBytes)
		if err != nil {
			return events.APIGatewayProxyResponse{}, err
		}
	}
	defer resp.Body.Close()

	// 转换Headers
	headers := make(map[string]string)
	for k, v := range resp.Header {
		headers[k] = strings.Join(v, ", ")
	}

	return events.APIGatewayProxyResponse{
		StatusCode:      resp.StatusCode,
		Headers:         headers,
		Body:            string(bodyBytes),
		IsBase64Encoded: false, // 如果返回二进制数据可改为true
	}, nil
}

关键注意事项 #

• 路由注册：必须为Fuego Server添加至少一条路由规则，否则所有请求都会返回404
• 上下文传递：将Lambda的ctx传递给HTTP请求，确保Fuego中间件能获取到Lambda上下文信息
• Header处理：API Gateway的Headers可能存在大小写问题，转换时直接原样复制即可
• Content-Type：如果请求包含Body，确保设置正确的Content-Type，否则Fuego的Bind功能无法正常解析请求体

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