如何在Golang版AWS Lambda中支持S3与SQS多触发器？

你的问题核心在于main函数里连续调用了两次lambda.Start()——Lambda的Go运行时只允许注册一个handler入口，而且lambda.Start()是阻塞式调用，所以第二个lambda.Start(ProcessIncomingEvents)永远不会被执行到。

要同时支持S3触发器和SQS触发器，你需要写一个通用的handler函数，通过类型断言区分不同事件类型，再分发给对应的处理逻辑。

示例实现代码 #

package main

import (
	"context"
	"fmt"
	"github.com/aws/aws-lambda-go/events"
	"github.com/aws/aws-lambda-go/lambda"
	"log"
)

func main() {
	// 只注册一个通用handler作为入口
	lambda.Start(HandleLambdaEvent)
}

// 通用handler，兼容多种事件类型
func HandleLambdaEvent(ctx context.Context, event interface{}) error {
	switch eventType := event.(type) {
	case events.S3Event:
		log.Println("Received S3 trigger event")
		return ProcessIncomingS3Events(eventType)
	case events.SQSEvent:
		log.Println("Received SQS trigger event")
		return ProcessIncomingSQSEvents(eventType)
	default:
		errMsg := fmt.Sprintf("unsupported event type: %T", eventType)
		log.Println(errMsg)
		return fmt.Errorf(errMsg)
	}
}

// 原有的S3事件处理逻辑
func ProcessIncomingS3Events(event events.S3Event) error {
	log.Println("Processing S3 event content")
	// 这里写入你的S3对象复制逻辑
	// return pr... 你的原有代码
	return nil
}

// 原有的SQS事件处理逻辑
func ProcessIncomingSQSEvents(event events.SQSEvent) error {
	log.Println("Processing SQS event content")
	// 这里写入解析S3变更信息并执行复制的逻辑
	return nil
}

关键说明 #

1. 通用handler的必要性：Lambda运行时会根据触发器类型自动序列化对应的事件结构体，我们通过interface{}接收后，用类型断言event.(type)判断具体事件类型，再分发处理。
2. 上下文传递：建议把context.Context传递给子处理函数，Lambda的上下文包含请求超时、请求ID等关键信息，能帮助你更好地处理超时和追踪请求链路。
3. 错误处理：对未知事件类型返回明确错误日志，方便后续排查问题。

这样你的Lambda函数就能同时响应S3触发器和SQS触发器的请求了。

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