Go编写的AWS Lambda经SQS触发时S3PutEvent为空如何排查

• 最简便可靠的方案：修改Lambda处理函数的入参类型为json.RawMessage，跳过AWS SDK预定义结构体的自动反序列化，直接打印原始字符串载荷，能100%拿到完整的传入事件内容，不会因为结构体字段不匹配丢失数据。
  参考修改代码：

  import "encoding/json"
  
  func HandleRequest(ctx context.Context, event json.RawMessage) error {
      // 打印完整原始事件
      fmt.Printf("Raw event: %s\n", string(event))
      return nil
  }
  

• 可选方案：在Lambda控制台配置测试事件时，选择SQS触发模板，填入SQS投递的真实事件样本测试；也可以在CloudWatch Logs中开启Lambda事件记录日志，但该方式会产生额外日志存储成本，优先级低于直接打印原始载荷。

你的触发链路是S3→SQS→Lambda，该链路下Lambda接收到的事件类型是events.SQSEvent，而非直接触发场景下的events.S3Event：S3产生的事件会被序列化后，放在SQS单条消息的body字段中，你直接用events.S3Event作为入参接收，反序列化时字段映射完全不匹配，自然打印出的字段全为空值。
控制台S3测试事件可以正常打印，是因为控制台测试时直接将S3Event结构的载荷发送给Lambda，没有经过SQS层的封装，和真实链路的载荷结构不一致。

正确的事件处理代码参考：

package main

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

func HandleRequest(ctx context.Context, sqsEvent events.SQSEvent) error {
    for _, record := range sqsEvent.Records {
        var s3Event events.S3Event
        // 从SQS消息体中解析真正的S3事件
        if err := json.Unmarshal([]byte(record.Body), &s3Event); err != nil {
            return fmt.Errorf("unmarshal s3 event failed: %w", err)
        }
        fmt.Printf("S3 event content: %+v\n", s3Event)
        // 后续业务逻辑处理s3Event即可
    }
    return nil
}

func main() {
    lambda.Start(HandleRequest)
}

注意：如果SQS队列开启了批量投递，单次触发的SQSEvent会包含多条S3事件消息，需要遍历所有Records逐一处理，避免漏处理。

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