Skip to main content

moregeek program

将 emqx cloud 数据通过公网桥接到 aws iot_emq的博客-多极客编程

在物联网业务场景中,往往涉及对海量物联设备产生数据的实时提取、过滤、分拆、转换等。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,您的应用程序可以随时跟踪您的所有设备并与其通信,即使这些设备未处于连接状态也不例外。


将 EMQX Cloud 数据通过公网桥接到 AWS IoT_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。

将 EMQX Cloud 数据通过公网桥接到 AWS IoT_数据集成_02

配置 AWS IoT

  1. 创建事务

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



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

  1. 创建并下载证书

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



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


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



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

  1. 创建策略并关联到证书

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



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

{
"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"
}
]
}

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



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

  1. 获取 AWS IoT 的公网连接地址

在设置获取到连接地址 endpoint,用于设备连接。



将 EMQX Cloud 数据通过公网桥接到 AWS IoT_数据集成_08

配置 EMQX Cloud 数据集成

进入 EMQX Cloud 的部署页面,点击数据集成 - MQTT Bridge。


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



在资源页面填写 AWS IoT 的资源详细信息。



将 EMQX Cloud 数据通过公网桥接到 AWS IoT_数据集成_10


确认资源可用以后,进行规则配置,筛选并处理数据。



将 EMQX Cloud 数据通过公网桥接到 AWS IoT_数据集成_11


配置好规则以后,需要配置响应动作,即桥接数据到 AWS IoT。


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


在完成创建资源 - 添加规则 - 添加动作以后,可在详情页面查看相关信息。



将 EMQX Cloud 数据通过公网桥接到 AWS IoT_物联网_13



查看已创建的规则,点击监控,可查看到目前桥接成功监控次数为 0,即初始化状态。



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

测试验证

  1. 使用 Python SDK 连接到 EMQX Cloud 部署,向主题 emqx/bridge 发送消息。

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

  1. 使用 MQTTX 连接到 AWS IoT,订阅 emqx/bridge,可以接收到来自 EMQX Cloud 部署的消息。

将 EMQX Cloud 数据通过公网桥接到 AWS IoT_数据集成_16


将 EMQX Cloud 数据通过公网桥接到 AWS IoT_物联网_17

  1. 在 EMQX Cloud console 查看规则监控,可以检查桥接数据到 AWS IoT 成功与否。

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

结语

至此,我们完成了使用 EMQX Cloud 数据集成功能通过公网桥接数据到 AWS IoT 的全部流程。EMQX Cloud 灵活的数据集成功能,结合 AWS IoT 丰富的应用生态,用户在数分钟内即可创建一款物联网应用。


版权声明: 本文为 EMQ 原创,转载请注明出处。

原文链接:​​https://www.emqx.com/zh/blog/bridging-emqx-cloud-data-to-aws-iot-over-the-public-network​

©著作权归作者所有:来自51CTO博客作者EMQ映云科技的原创作品,请联系作者获取转载授权,否则将追究法律责任
将 EMQX Cloud 数据通过公网桥接到 AWS IoT
https://blog.51cto.com/u_15204296/5430940

硬件开发笔记(八): 硬件开发基本流程,制作一个usb转rs232的模块(七):创建基础dip元器件(晶振)封装并关联原理图元器件_长沙红胖子qt的博客-多极客编程

前言   有了原理图,可以设计硬件PCB,在设计PCB之间还有一个协同优先动作,就是映射封装,原理图库的元器件我们是自己设计的。为了更好的表述封装设计过程,本文描述了创建晶振封装(DIP),将原理图的元器件关联引脚封装。 <br> 原理图封装剖析    序号1:USB口封装,查看datasheet创建 序号2:CON封装,使用dip2.54,2dip 序号3:ASM1117-3.3V封

什么是低代码开发?_mb6231489e297cd的博客-多极客编程

随着企业数字化和上云的趋势愈演愈烈,越来越多的个性化SaaS应用,需要更快、更高效的开发。低代码开发是一种通过可视化进行应用程序开发的方法,使具有不同经验水平的开发人员可以通过图形化的用户界面,使用拖拽组件和模型驱动的逻辑来创建网页和移动应用程序。低代码开发平台使非技术开发人员可不必编写代码,而是将传统IT架构抽象化来支持专业开发人员。业务部门和IT部门的开发人员可以共同创建、迭代和发布应用程序,

全志v853芯片 如何在tina v85x平台切换sensor?_神棍地海棠的博客-多极客编程

目的 V85x某方案目前默认Sensor是GC2053。实际使用时若需要用到GC4663(比如wdr功能)和SC530AI(支持500W),可按如下步骤完成切换。 步骤 下面以GC4663为例,SC530AI按相应方式适配。 Step1 检查Sensor驱动是否被编译成.ko文件GC4663 Sensor驱动文件gc4663_mipi.c和配置Sensor驱动编译的Makefile文件路径的路径:

台湾sss鑫创sss1700替代cmedia cm6533 24bit 96khz usb音频编解码芯片_mb619b106ab8347的博客-多极客编程

台湾鑫创在2021年推出一款芯片SSS1700可以替代兼容CM6533,不管在音质和兼容性方面都优于Cmedia CM6533,且SSS1700外围电路较简单易设计,芯片成本比Cmedia CM6533要低,整体方案性价较Cmedia CM6533也更具有优势。下面分别讲解Cmedia CM6533与SSS1700参数特性: Cmedia CM6533是一款USB音频编解码器,内部嵌入8051内核

cs5268优势替代ag9321mcq typec多合一扩展坞方案_mb619b106ab8347的博客-多极客编程

台湾安格AG9321MCQ是一款TYPEC拓展坞产品方案,他集中了TYPEC 转HDMI  VGA  PD3.0快充  QC3.0数据传输 I2S接口的音频DAC输出以及可以各种读卡器功能。AG9321MCQ特色1.双USB C型接口USB电源传输3.0符合性四个配置通道(CC),带有onchip Rp/Rd电阻器双重角色权力和快速角色互换2.显示端口接收器VESA显示端口™ 1.2合规性5.4(

硬件开发笔记(九): 硬件开发基本流程,制作一个usb转rs232的模块(八):创建asm1117-3.3v封装库并关联原理图元器件_长沙红胖子qt的博客-多极客编程

前言   有了原理图,可以设计硬件PCB,在设计PCB之间还有一个协同优先动作,就是映射封装,原理图库的元器件我们是自己设计的。为了更好的表述封装设计过程,本文描述了一个创建asm1117-3.3V封装,将原理图的元器件关联引脚封装。 <br> 原理图封装剖析    序号1:USB口封装,查看datasheet创建 序号2:COM封装,使用dip2.54,2dip 序号3:ASM111

什么是低代码开发?_mb6231489e297cd的博客-多极客编程

随着企业数字化和上云的趋势愈演愈烈,越来越多的个性化SaaS应用,需要更快、更高效的开发。低代码开发是一种通过可视化进行应用程序开发的方法,使具有不同经验水平的开发人员可以通过图形化的用户界面,使用拖拽组件和模型驱动的逻辑来创建网页和移动应用程序。低代码开发平台使非技术开发人员可不必编写代码,而是将传统IT架构抽象化来支持专业开发人员。业务部门和IT部门的开发人员可以共同创建、迭代和发布应用程序,

emq 助力青岛研博建设智慧水务平台_emq的博客-多极客编程

在城市水务行业中,各省市水务集团与水务公司作为国有资产管理和基础设施投资运营主体,负责城镇供水、排水防汛、污水处理、中水回用、河道运维、污泥处置、海水淡化、水务工程建设等各类水务相关业务。根据国务院国资委与各地方国资委新基建数字化转型以及智慧水务规划的目标任务,各水务运营主体提出了通过数字化转型提升集团生产效能,助推水务事业高质量发展的要求。水务业务的数字化转型过程可分为「数据先行、夯实基础」、「

车联网中 mqtt 心跳保活与远程唤醒设计_emq的博客-多极客编程

随着车联网的快速发展,其应用场景也越来越丰富。除了在车辆行驶中进行相关数据传输上报,在车辆熄火状态下也可实现远程控车(远程启动、开启空调与开后备箱等)、OTA 升级等场景需求。为了给车主提供低时延、高成功率的使用体验,需要通过车联网平台与车机的心跳保活机制,保持长连接状态,并在车辆熄火的情况下快速远程唤醒车机,实现远程控车。本篇文章将介绍车联网平台中 ​​MQTT​​ 的心跳保活和远程唤醒设计。M

hstreamdb newsletter 2022-06|新集群机制、可视化监控、python 客户端发布…_emq的博客-多极客编程

本月,HStreamDB 团队专注于 v0.9 的开发工作,目前已经完成了 HServer 去中心化集群的切换、HStream IO Embedded Runtime 和 CDC Source Connector 的开发, 并带来了新的 Grafana 监控集成以及正式发布了首个可用的 Python 客户端。另外,还与 EMQX 团队协作完成了 HStreamDB 与 EMQX 的集成。HServ

emqx newsletter 2022-06|与 hstreamdb 集成、充电桩通信协议 ocpp 网关开发…_emq的博客-多极客编程

继 EMQX 5.0.0-rc.4 发布之后,v5.0 的开发工作已经接近尾声。除了继续优化 Dashboard 的 UI/UX 以提升使用体验,和测试并修复各项 Bug 以提升软件稳定性以外,EMQX 团队也在对用户文档进行全面的改进和更新,不久后即将为用户带来一个更加强大易用的 EMQX 5.0。云服务方面,EMQX Cloud 本月新增了JWT 认证支持,用户进行认证鉴权时又多了一种选择。此

nanomq newsletter 2022-06|规则引擎正式发布 & nanosdk 支持 mqtt over quic_emq的博客-多极客编程

NanoMQ 继续保持稳步更新,0.9.0 将于 7 月初正式发布。此版本为大家带来了 2 个重要的功能更新:规则引擎和支持 QUIC 的 NanoSDK。同时还增加了离线数据缓存配置,各项性能优化和缺陷修复也在持续进行中。轻便易用的嵌入式规则引擎规则引擎是 EMQX 深受广大用户喜爱的一项功能,NanoMQ 也根据用户需求推出了相同的功能,用户现在可以方便地通过编写 SQL 规则对消息进行处理后