EMQX Cloud 数据集成保存数据到 AWS RDS MySQL

EMQX 企业版技术支持发表于:2022年11月10日 10:50:43更新于:2022年11月10日 10:52:19

在本文中我们将模拟温湿度数据并通过 MQTT 协议上报到 EMQX Cloud,然后使用 EMQX Cloud 数据集成将数据转存到 AWS RDS MySQL。

在开始之前,您需要完成以下操作:

已经在 EMQX Cloud 上创建部署(EMQX 集群)。

对于专业版部署用户:请先完成对等连接的创建,下文提到的 IP 均指资源的内网 IP。

创建AWS RDS MySQL

如果您是初次接触 AWS RDS MySQL,建议您跟随 AWS RDS MySQL 的官方文档:

https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/CHAP_GettingStarted.CreatingConnecting.MySQL.html#CHAP_GettingStarted.Creating.MySQL

1、为了方便测试,这里我们选择的配置如下:

image.png

可以看到默认生成的实例暂无数据库名称,所以需要在实例中创建数据库,填入到 EMQX Cloud 数据集成- MySQL 资源- MySQL 数据库名。(下面有详细步骤)

2、需要特别注意的是:创建实例时网络类型选 IPV4,并选择与 EMQX Cloud 建立了对等连接的 VPC 和对应的子网。

image.png

3、连接到运行 MySQL 数据库引擎的数据库实例上的数据库

选择 vpc 内的 ec2 实例,执行以下命令,尝试看看是否能通过内网地址访问 MySQL 实例:

##安装 mysql client
sudo apt-get install mysql-client
##连接到实例
mysql -h <内网地址> -P 3306 -u <用户名> -p
输入密码:xxx

image.png

测试连接成功后,创建数据库和表,可参阅:https://docs.emqx.com/zh/cloud/latest/rule_engine/rule_engine_save_mysql.html#mysql-%E9%85%8D%E7%BD%AE

##创建数据库实例
CREATE DATABASE emqx; 
USE emqx;

image.png

数据集成配置

1、资源可用性

image.png

测试连接成功以后,可进行下一步规则创建-响应动作创建。

image.png

测试

1、使用 MQTTX 模拟温湿度数据上报:

image.png

2、查看数据转存结果

image.png

    您需要登录后才可以回复