保存数据到 SQLServer

搭建 SQLServer 数据库，并设置用户名密码为 sa/mqtt_public，以 MacOS X 为例:

  1. docker run -e 'ACCEPT_EULA=Y' -e 'SA_PASSWORD=mqtt_public' -p 1433:1433 -d mcr.microsoft.com/mssql/server:2017-latest

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

  1. $ /opt/mssql-tools/bin/sqlcmd -S localhost -U sa -P mqtt_public -d master
  2. $ mysql -u root -h localhost -ppublic

创建 “test” 数据库:

  1. CREATE DATABASE test;
  2. go;

创建 t_mqtt_msg 表:

  1. USE test;
  2. go;
  3. CREATE TABLE t_mqtt_msg (id int PRIMARY KEY IDENTITY(1000000001,1) NOT NULL,
  4.                          msgid   VARCHAR(64) NULL,
  5.                          topic   VARCHAR(100) NULL,
  6.                          qos     tinyint NOT NULL DEFAULT 0,
  7.                          payload NVARCHAR(100) NULL,
  8.                          arrived DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP);
  9. go;

配置 odbc 驱动:

  1. $ brew install unixodbc freetds
  2. $ vim /usr/local/etc/odbcinst.ini
  4. [ms-sql]
  5. Description = ODBC for FreeTDS
  6. Driver      = /usr/local/lib/libtdsodbc.so
  7. Setup       = /usr/local/lib/libtdsodbc.so
  8. FileUsage   = 1

创建规则:

打开 EMQ X Dashboard保存数据到 SQLServer - 图1 (opens new window)，选择左侧的 “规则” 选项卡。

填写规则 SQL:

  1. SELECT * FROM "t/#"

image

关联动作:

在 “响应动作” 界面选择 “添加”，然后在 “动作” 下拉框里选择 “保存数据到 SQLServer”。

image

填写动作参数:

“保存数据到 SQLServer” 动作需要两个参数： 4 2). SQL 模板。这个例子里我们向 SQLServer 插入一条数据，SQL ​ 模板为:

  1. insert into t_mqtt_msg(msgid, topic, qos, payload) values ('${id}', '${topic}', ${qos}, '${payload}')

image

1). 关联资源的 ID。现在资源下拉框为空，可以点击右上角的 “新建资源” 来创建一个 SQLServer 资源:

填写资源配置: 数据库名填写 “mqtt”，用户名填写 “sa”，密码填写 “mqtt_public”

image

点击 “新建” 按钮。

返回响应动作界面，点击 “确认”。

image

返回规则创建界面，点击 “创建”。

image

在规则列表里，点击 “查看” 按钮或规则 ID 连接，可以预览刚才创建的规则:

image

规则已经创建完成，现在发一条数据:

  1. Topic: "t/a"
  2. QoS: 1
  3. Payload: "hello"

然后检查 SQLServer 表，新的 record 是否添加成功:

image