# 集成 SQL Server

注意

该功能在基础版中不可用

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

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

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

# SQLServer 配置

SQLServer 安装

# 密码需要大小写和特殊字符的组合
docker run -e 'ACCEPT_EULA=Y' -e 'SA_PASSWORD=Mqtt_public' -p 1433:1433 -d mcr.microsoft.com/mssql/server:2017-latest

1
2

进入 SQLServer 容器，初始化 SQLServer 表:

sqlcmd -S localhost -U sa -P Mqtt_public -d master

创建数据库

CREATE DATABASE emqx;
go;

1
2

USE emqx;
go;

1
2

温湿度表创建

使用以下 SQL 语句将创建 temp_hum 表，该表将用于存放设备上报的温度和湿度数据。

CREATE TABLE temp_hum(client_id VARCHAR(64) NULL,
                      temp NVARCHAR(100) NULL,
                      hum NVARCHAR(100) NULL,
                      up_timestamp DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP);
                      
go;

1
2
3
4
5
6

配置 odbc 驱动
通过 EMQX Cloud 工单 (opens new window) 服务提供您的 SQL Server 版本，后台将为您的部署安装 odbc 驱动。

# EMQX Cloud 数据集成配置

创建资源
点击左侧菜单栏数据集成，在数据持久化下找到 Microsoft SQL Server，点击新建资源。
填入刚才创建好的 SQLServer 数据库信息，并点击测试，如果出现错误应及时检查数据库配置是否正确。
创建规则
资源创建后点击新建规则，然后输入如下规则匹配 SQL 语句。在下面规则中我们从 temp_hum/emqx 主题读取消息上报时间 up_timestamp、客户端 ID、消息体(Payload)，并从消息体中分别读取温度和湿度。
```
SELECT
timestamp as up_timestamp, clientid as client_id, payload.temp as temp, payload.hum as hum
FROM
"temp_hum/emqx"  
```
1
2
3
4
我们可以使用 SQL 测试 来测试查看结果
添加响应动作
点击下一步来到动作界面，选择第一步创建好的资源，动作类型选择数据持久化 - 保存数据到 SQLServer，并输入以下数据插入 SQL 模板，点击确认。
```
insert into temp_hum(client_id, temp, hum) values ('${client_id}', '${temp}', '${hum}') 
```
1
查看资源详情
动作创建完以后，返回列表点击资源 ID 可以查看详情和监控信息
查看规则详情
规则详情界面点击规则 ID 可以查看规则规则详情

# 测试

使用 MQTTX (opens new window) 模拟温湿度数据上报
需要将 broker.emqx.io 替换成已创建的部署连接地址，并添加客户端认证信息。
- topic: temp_hum/emqx
- payload:
```
{
   "temp": "24.1",
   "hum": "34.5"
}
```
  1
  2
  3
  4

查看数据转存结果

select * from temp_hum order by up_timestamp;

sqlserver

← 集成 InfluxDB 2.0 集成 TDengine →