如何使用AWS IoT Core规则重发布GetStream消息至新MQTT主题
问题排查与解决
你的问题出在AWS IoT保留主题的特殊处理逻辑,以及混淆了设备证书策略和规则执行角色权限的区别,具体修复点如下:
1. 核心修正:给IoT规则的执行角色配置对应权限
你之前修改的是设备的IoT证书策略,但IoT规则的转发操作是由AWS IoT服务代你执行的,它依赖的是规则绑定的IAM执行角色的权限,和设备权限无关。
必须给这个执行角色添加以下权限:
- 允许读取源保留主题的消息:需要
iot:Subscribe和iot:Receive权限,资源匹配$aws/things/+/streams/+/data/json的ARN - 允许向目标主题
devices/data发布消息:iot:Publish权限
示例IAM策略(替换你的账号和区域):
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": ["iot:Subscribe", "iot:Receive"], "Resource": "arn:aws:iot:us-east-1:162502870742:topicfilter/$aws/things/+/streams/+/data/json" }, { "Effect": "Allow", "Action": "iot:Publish", "Resource": "arn:aws:iot:us-east-1:162502870742:topic/devices/data" } ] }
2. 修正设备策略的语法错误
你修改后的设备策略存在语法问题:第一个Statement里的Resource值末尾缺少闭合双引号,这会导致策略失效。如果需要设备能接收devices/data的消息,修正后的策略如下:
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": "iot:Publish", "Resource": "arn:aws:iot:us-east-1:162502870742:topic/devices/data" }, { "Effect": "Allow", "Action": "iot:Receive", "Resource": "*" } ] }
3. 验证规则配置细节
- 确认SQL语句
SELECT * FROM '$aws/things/+/streams/+/data/json'没有语法错误,单引号和通配符使用正确 - 用AWS IoT控制台的规则测试工具,模拟发送一条源主题的消息,验证是否能转发到目标主题,快速定位是规则问题还是设备端问题
- 检查规则是否设置了额外的WHERE筛选条件,导致符合条件的消息被过滤
内容的提问来源于stack exchange,提问作者Harrison Kaiser
相关产品推荐
相关产品推荐

