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

在本文中我们将模拟温湿度数据并通过 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、为了方便测试，这里我们选择的配置如下：

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

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

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

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

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

测试连接成功后，创建数据库和表，可参阅：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;

1、资源可用性

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

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

2、查看数据转存结果