当AWS IoT Core接收MQTT消息时，能否向外部REST服务发送请求？

方法一：通过Lambda直接调用外部REST接口 #

这是最常用的方案，Lambda策略模板默认只展示AWS服务，但你完全可以自定义配置实现对外请求：

1. 编写Lambda函数
   用对应语言实现REST调用逻辑，比如Python示例：

   import requests
   import json
   
   def lambda_handler(event, context):
       # 解析IoT Core传递的消息
       message_payload = json.dumps(event)
       # 替换为你的外部服务REST地址
       target_url = "http://your-service-ip/api/ingest"
       headers = {"Content-Type": "application/json"}
       
       try:
           resp = requests.post(target_url, data=message_payload, headers=headers)
           resp.raise_for_status()
           return {"statusCode": 200, "body": "Data forwarded successfully"}
       except Exception as e:
           return {"statusCode": 500, "body": f"Forward failed: {str(e)}"}
   

2. 配置Lambda网络权限

   • 若外部服务为公网可访问：保持Lambda默认的公网环境，确保Lambda执行角色的信任关系包含lambda.amazonaws.com，同时安全组允许出站HTTP/HTTPS请求。
   • 若外部服务部署在EC2（VPC内）：将Lambda部署到EC2所在VPC的私有子网，配置安全组允许Lambda访问EC2的REST端口（如80/443），并为Lambda执行角色添加VPC访问所需的IAM权限（如ec2:CreateNetworkInterface、ec2:DescribeNetworkInterfaces等）。

3. 关联IoT Core规则
   在AWS IoT Core创建规则，触发动作选择「Invoke Lambda function」，将目标设为你创建的Lambda函数即可。

方法二：以EC2作为中间转发层 #

如果偏好EC2作为中转节点，有两种实现方式：

方式A：EC2订阅IoT Core MQTT主题 #

• 在EC2上部署MQTT客户端，使用IoT Core颁发的证书/密钥连接到IoT Core的MQTT端点，订阅设备发送消息的主题。
• 客户端收到消息后，直接调用本地或外部的REST接口完成数据存储。

方式B：IoT Core规则直接调用EC2 REST接口 #

• 开启IoT Core的HTTP动作支持，在规则中添加「HTTP」动作，填写EC2的公网IP/域名及REST接口路径。
• 若接口需要认证，可配置Basic Auth或自定义签名头；同时确保EC2安全组允许IoT Core服务IP段访问对应端口（可通过AWS官方文档查询IoT Core的IP范围）。

关键注意事项 #

• 安全控制：为REST接口添加身份验证（如API密钥、OAuth2），并限制访问源IP（仅允许Lambda VPC IP或IoT Core服务IP），避免未授权访问。
• 可靠性保障：若外部服务存在可用性风险，可引入SQS做消息缓冲——先将IoT Core消息写入SQS，再由Lambda或EC2消费SQS消息并调用REST接口，防止消息丢失。
• 性能扩容：高消息量场景下，需调整Lambda并发限制或配置EC2自动扩容，确保转发能力匹配消息吞吐量。

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