AWS IoT Core能否订阅本地Solace Broker的MQTT主题并触发Lambda？

完全可以通过AWS IoT Core实现托管式的Solace MQTT主题订阅，无需依赖EC2实例的客户端，下面是具体实现步骤：

1. 配置AWS IoT Core连接到本地Solace Broker #

• 在AWS IoT控制台创建一个Thing，生成对应的X.509证书、私钥和根CA证书（如果Solace采用证书认证），或者准备好Solace的用户名密码（如果采用账号密码认证）。
• 进入IoT Core的MQTT客户端页面，创建一个新的客户端连接：
  • 填写Solace Broker的MQTT端点（例如tcp://your-solace-local-ip:1883或ssl://your-solace-local-ip:8883，根据你的Solace配置选择）。
  • 配置认证方式：如果用证书，将IoT Core生成的证书导入Solace Broker的信任存储；如果用账号密码，直接填写Solace的认证信息。
  • 订阅目标MQTT主题（例如your/solace/topic），确保订阅权限在Solace侧已开放。

2. 创建IoT Core规则转发消息到Lambda #

• 在IoT Core控制台创建规则：
  • 编写SQL语句匹配订阅的主题，例如SELECT * FROM 'your/solace/topic'。
  • 添加Lambda动作，选择你需要触发的Lambda函数，IoT Core会自动生成具备调用Lambda权限的IAM角色（也可以手动配置权限）。

3. 配置Solace Broker的访问权限 #

• 在Solace管理控制台中，确保允许IoT Core的客户端连接：
  • 如果是证书认证，将IoT Core的根CA证书添加到Solace的信任链。
  • 给对应的客户端（或用户名）配置订阅权限，允许访问目标MQTT主题。

额外：对接AppSync的方案 #

当Lambda被触发后，你可以在Lambda代码中调用AppSync的GraphQL API（通过Mutation操作），将Solace传来的消息同步到AppSync的数据源，实现后端数据的实时更新。

替代托管方案 #

如果IoT Core的配置对你来说过于繁琐，还可以考虑：

• 使用Solace的Webhook触发器：将Solace主题的消息直接推送到AWS API Gateway，再由API Gateway触发Lambda，同样是托管式方案。
• 使用AWS EventBridge：通过Solace的HTTP输出将消息发送到EventBridge的自定义事件总线，再由EventBridge规则触发Lambda。

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