集成到阿里云 MongoDB

WARNING

该功能在基础版中不可用

在本文中我们将模拟温湿度数据并通过 MQTT 协议上报到 EMQX Cloud，然后使用 EMQX Cloud 数据集成将数据转存到阿里云 MongoDB。

在开始之前，您需要完成以下操作：

已经在 EMQX Cloud 上创建部署(EMQX 集群)
已经在阿里云上创建云数据库MongoDB 资源
对于专业版部署用户：请先完成对等连接的创建，下文提到的 IP 均指资源的内网 IP。(专业版部署若开通 NAT 网关也可使用公网 IP 进行连接）
对于 BYOC 部署用户：请首先为 BYOC 部署所在的 VPC 与资源所在的 VPC 之间建立对等连接。注：下文提到的 IP 均指资源的内网 IP。如需通过公网地址访问资源，请首先在您的公有云控制台中为 BYOC 部署所在 VPC 配置 NAT 网关。

购买阿里云 MongoDB

创建资源
点击左侧菜单栏数据集成，在数据持久化下找到 MongoDB Relica Set 模式，点击新建资源。
请根据阿里云控制台提供的信息，填写以下参数
- MongoDB 服务器
- 数据库名称
- 连接池大小
- 用戶名
- 密码
- 连接认证源
- 数据集名称
其中, 服务器地圵和 副本集名称 可以在阿里云控制台，下图的位置找到
规则测试
资源创建后点击新建规则，然后输入如下规则匹配 SQL 语句。在下面规则中我们从 temp_hum/emqx 主题读取消息上报时间 up_timestamp、客户端 ID、消息体(Payload)，并从消息体中分别读取温度和湿度。
sql
```
SELECT
  
timestamp as up_timestamp, clientid as client_id, payload.temp as temp, payload.hum as hum 
  
FROM
  
"temp_hum/emqx"
```
添加响应动作
点击下一步来到动作界面，选择第一步创建好的资源，动作类型选择数据持久化 - 保存数据到 MongoDB，并填写 Collection，点击确认。
查看资源详情
动作创建完以后，返回列表点击资源可以查看详情
查看规则详情
资源详情界面点击规则可以查看规则监控信息和规则详情