将 EMQX Cloud 数据通过公网桥接到 AWS IoT

EMQX Cloud Team

2022-6-28

在物联网业务场景中，往往涉及对海量物联设备产生数据的实时提取、过滤、分拆、转换等。EMQ 推出的全托管云原生 MQTT 消息服务 EMQX Cloud 提供了高性能的内置数据集成功能，可以帮助用户实现与各种云服务（如 Kafka、MongoDB、AWS RDS、AWS DocumentDB、 AWS IoT 等）的连接，将物联网数据根据需求转存到各类第三方数据库、消息队列、数据系统中，从而简化物联网应用开发，加速业务交付。

本文将介绍如何使用 EMQX Cloud 数据集成功能通过公网桥接数据到 AWS IoT，从而借助 AWS IoT 轻松使用 AWS Lambda、Amazon Kinesis、Amazon S3、Amazon Machine Learning、Amazon DynamoDB、Amazon CloudWatch、AWS CloudTrail 和内置 Kibana 集成的 Amazon Elasticsearch Service 等 AWS 服务构建 IoT 应用程序。无需管理任何基础设施，即可实现对互连设备生成数据的收集、处理和分析等相关操作。

AWS IoT 简介

什么是 AWS IoT

Amazon IoT Core 是一种托管的云平台，让互联设备可以轻松安全地与云应用程序和其他设备交互。Amazon IoT 可以支持数十亿台设备和数万亿条消息，并能处理这些消息并将其安全可靠地路由至亚马逊云科技终端节点和其他设备。借助 Amazon IoT，您的应用程序可以随时跟踪您的所有设备并与其通信，即使这些设备未处于连接状态也不例外。

AWS IoT 平台的优势

（1）广泛而深入：AWS 拥有从边缘到云端的广泛而深入的 IoT 服务，提供本地数据收集和分析能力以及云上专为 IoT 设计的数据管理和丰富分析集成服务。

（2）多层安全性：包括预防性安全机制（如设备数据的加密和访问控制）、持续监控和审核安全配置等。

（3）卓越的 AI 集成：AWS 将 AI 和 IoT 结合在一起，使设备更为智能化。支持多种机器学习框架。

（4）大规模得到验证：AWS IoT 构建于可扩展、安全且经过验证的云基础设施之上，可扩展到数十亿种不同的设备和数万亿条消息。

使用 EMQX Cloud 桥接数据到 AWS IoT

开通 NAT 网关

在 EMQX Cloud 部署详情页面，开通增值服务 --- NAT 网关，便于公网访问到 AWS IoT。

配置 AWS IoT

创建事务

进入 AWS IoT 控制面板，找到管理-事务，点击创建事务，即可创建一个名为 emqx 的事务。
创建并下载证书

在创建好事务以后，可直接创建一个证书。

证书创建完成以后，需要在该页面下载证书，用于设备连接时的双向认证。

创建策略并关联到证书

找到安全-策略，创建名为 emqx-bridge 的策略，编写策略，相关配置如下。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "iot:Connect",
      "Resource": "arn:aws:iot:us-east-1:845523974165:client/emqx-bridge_*"
    },
    {
      "Effect": "Allow",
      "Action": "iot:Publish",
      "Resource": "arn:aws:iot:us-east-1:845523974165:topic/emqx/bridge"
    },
    {
      "Effect": "Allow",
      "Action": "iot:Receive",
      "Resource": "arn:aws:iot:us-east-1:845523974165:topic/emqx/bridge"
    },
    {
      "Effect": "Allow",
      "Action": "iot:RetainPublish",
      "Resource": "arn:aws:iot:us-east-1:845523974165:topic/emqx/bridge"
    },
    {
      "Effect": "Allow",
      "Action": "iot:Subscribe",
      "Resource": "arn:aws:iot:us-east-1:845523974165:topicfilter/emqx/bridge"
    }
  ]
}

完成策略创建以后，需要关联到前一步创建好的证书。