Save data to TDengine

EMQX 支持通过 发送到 Web 服务 的方式保存数据到 TDengine，也在企业版上提供原生的 TDengine 驱动实现直接保存。

使用 Docker 安装 TDengine 或在 Cloud (opens new window) 上部署：

进入 Docker 容器：


taos

创建 “test” 数据库:

create database test;

创建 t_mqtt_msg 表，关于 TDengine 数据结构以及 SQL 命令参见：

创建规则:

打开 EMQX Dashboard (opens new window)，选择左侧的 “规则” 选项卡。

填写规则 SQL:

SELECT
  now_timestamp('millisecond')  as ts
FROM
  "#"

后续动作创建操作可以根据你的 EMQX 版本灵活选择。

关联动作:

填写动作参数:

“保存数据到 TDengine” 动作需要两个参数：

insert into test.t_mqtt_msg(ts, msgid, mqtt_topic, qos, payload, arrived) values (${ts}, '${id}', '${topic}', ${qos}, '${payload}', ${timestamp})

填写资源配置:

用户名填写 “root”，密码填写缺省密码 “taosdata”，TDengine 不在资源中配置数据库名，请在 SQL 中自行配置。

点击 “新建” 按钮。

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

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

为支持各种不同类型平台的开发，TDengine 提供符合 REST 设计标准的 API。通过提供了最简单的连接方式，即使用 HTTP 请求携带认证信息与要执行的 SQL 操作 TDengine。

关联动作:

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

EMQX 规则引擎中有功能强大的****发送数据到 Web 服务功能****，可以实现无缝实现上述操作。

填写动作参数:

“保存数据到 Web 服务” 动作需要 5 个参数：

Method：HTTP 请求方式，使用 POST
Path：写入数据路径 /rest/sql
Headers：使用认证，默认用户名密码 “root:taosdata” base64 编码 cm9vdDp0YW9zZGF0YQ==
Body：请求体这个例子里我们向 TDengine 插入一条数据，应当在请求体内拼接携带 INSERT SQL 。注意我们应当在 SQL 中指定数据库名，字符类型也要用单引号括起来，消息内容模板为：

在规则列表里，点击规则 ID 连接，可以预览刚才创建的规则:

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

Topic: "t/a"
QoS: 1
Payload: {"msg": "hello"}

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

select * from t_mqtt_msg;