使用Golang调用AWS IoT Data Plane PublishInput时Payload为空求助

问题排查步骤与解决方案 #

1. 添加错误处理与日志验证
   先不要忽略json.Marshal的错误，同时打印Payload的内容和长度，确认序列化结果正确，排除序列化环节的问题：

   payload, err := json.Marshal(resp)
   if err != nil {
       log.Errorf("序列化Response失败: %v", err)
       return err
   }
   // 打印Payload信息，确认内容非空且格式正确
   log.Printf("序列化后的Payload: %s，长度: %d", string(payload), len(payload))
   

   查看Lambda的CloudWatch日志，确认这里输出的内容符合预期。

2. 调整PayloadFormatIndicator配置
   你当前设置的PayloadFormatIndicatorUtf8Data理论上适配UTF-8格式的JSON，但部分场景下IoT Core对该字段的解析存在兼容性问题。尝试两种调整：

   • 直接移除PayloadFormatIndicator字段，让SDK自动处理Payload格式
   • 切换为二进制格式标识：

     PayloadFormatIndicator: aws.String(iotdataplane.PayloadFormatIndicatorBinary),
     

3. 确认SDK版本与调用逻辑
   若使用AWS SDK for Go v1，确保依赖的github.com/aws/aws-sdk-go是最新版本，旧版本可能存在Payload传递bug。如果问题依旧，可尝试切换到AWS SDK for Go v2，其IoT Data Plane的Publish API逻辑更简洁：

   // v2示例代码片段
   import "github.com/aws/aws-sdk-go-v2/service/iotdataplane"
   
   client := iotdataplane.NewFromConfig(cfg)
   _, err := client.Publish(context.TODO(), &iotdataplane.PublishInput{
       Topic:   aws.String(topic),
       Payload: payload,
       Qos:     aws.Int32(0),
   })
   

4. 验证IAM权限与Topic配置
   确认Lambda的IAM角色拥有iot:Publish权限，且目标Topic不存在订阅过滤规则导致Payload被过滤。可通过开启IoT Core的CloudWatch日志，进一步排查消息流转情况。

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