Lambda调用IoT Core SDK发布消息时遇MissingEndpoint错误求助

这个错误其实很常见，核心原因是IoT Core的数据平面服务（iotdataplane）没有通用的区域默认端点——不像S3、EC2这类服务有统一的区域域名，每个AWS账户在每个区域的IoT Core都有一个专属的数据端点，你必须明确指定它才能正常调用Publish接口。

步骤1：获取你的IoT Core数据端点 #

有两种简单方式拿到这个专属端点：

• 登录AWS控制台进入IoT Core服务，左侧导航栏点击「设置」，页面里就能找到「数据端点」（格式通常是xxxxxx-ats.iot.eu-west-2.amazonaws.com）；
• 用AWS CLI命令直接查询：

  aws iot describe-endpoint --endpoint-type iot:Data-ATS --region eu-west-2
  

  执行后会返回包含endpointAddress的JSON结果，那就是你需要的端点。

步骤2：修改代码添加端点配置 #

在你原来的代码中，给AWS Config加上Endpoint参数，指定刚才拿到的专属端点。修改后的完整代码示例如下：

import (
    "fmt"
    "os"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/iotdataplane"
)

func publish() error {
    // 推荐：从Lambda环境变量获取端点，避免硬编码
    iotEndpoint := os.Getenv("IOT_ENDPOINT")
    if iotEndpoint == "" {
        return fmt.Errorf("IOT_ENDPOINT environment variable not set")
    }

    sess := session.New(&aws.Config{
        Region:   aws.String("eu-west-2"),
        Endpoint: aws.String(iotEndpoint), // 关键：添加这一行指定专属端点
    })

    iotClient := iotdataplane.New(sess)

    input := &iotdataplane.PublishInput{
        Payload: []byte("take picture"),
        Topic:   aws.String("take-picture"),
        Qos:     aws.Int64(1), // 根据需求设置QoS级别，可选但推荐明确指定
    }

    _, err := iotClient.Publish(input)
    if err != nil {
        return fmt.Errorf("failed to publish to IoT Core: %w", err)
    }

    return nil
}

额外注意事项 #

• 避免硬编码端点：把端点存在Lambda的环境变量里（控制台「配置」>「环境变量」中添加），后续变更端点或部署到其他区域时，不用修改代码；
• IAM权限检查：确保Lambda执行角色拥有iot:Publish权限，比如给角色附加这样的策略：

  {
      "Version": "2012-10-17",
      "Statement": [
          {
              "Effect": "Allow",
              "Action": "iot:Publish",
              "Resource": "arn:aws:iot:eu-west-2:YOUR_ACCOUNT_ID:topic/take-picture"
          }
      ]
  }
  

  替换YOUR_ACCOUNT_ID为你的AWS账户ID，生产环境不建议用*匹配所有主题。

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