保存数据到 InfluxDB
搭建 InfluxDB 数据库环境,以 macOS X 为例:
$ docker pull influxdb
$ docker run --name=influxdb --rm -d -p 8086:8086 -p 8089:8089/udp -v ${PWD}/files/influxdb.conf:/etc/influxdb/influxdb.conf influxdb:latest
EMQ X 仅支持通过 UDP 协议连接 InfluxDB,需要修改默认 InfluxDB 配置文件如下:
[[udp]]
enabled = true
bind-address = ":8089"
# 消息保存的数据库
database = "emqx"
# InfluxDB precision for timestamps on received points ("" or "n", "u", "ms", "s", "m", "h")
# EMQ X 默认时间戳是毫秒
precision = "ms"
# 其他配置根据需要自行修改
# batch-size = 1000
# batch-pending = 5
# batch-timeout = "5s"
# read-buffer = 1024
创建规则:
打开 emqx dashboard,选择左侧的 “规则” 选项卡。
选择触发事件 “消息发布”,然后填写规则 SQL:
SELECT
payload as p,
p.host as host,
p.location as location,
p.internal as internal,
p.external as external
FROM
"#"
关联动作:
在 “响应动作” 界面选择 “添加”,然后在 “动作” 下拉框里选择 “保存数据到 InfluxDB”。
填写动作参数:
“保存数据到 InfluxDB” 动作需要六个参数:
1). Measurement。指定写入到 InfluxDB 的 data point 的 measurement。
2). Field Keys。指定写入到 InfluxDB 的 data point 的 fields 的值从哪里获取。
3). Tags Keys。指定写入到 InfluxDB 的 data point 的 tags 的值从哪里获取。
4). Timestamp Key。指定写入到 InfluxDB 的 data point 的 timestamp 的值从哪里获取。
5). 设置时间戳。未指定 Timestamp Key 时是否自动生成。
6). 关联资源。现在资源下拉框为空,可以点击右上角的 “新建资源” 来创建一个 InfluxDB 资源:
选择 “InfluxDB 资源”:
填写资源配置:
本示例中所有配置保持默认值即可,点击 “测试连接” 按钮,确保连接测试成功。
最后点击 “新建” 按钮。
返回响应动作界面,点击 “确认”。 返回规则创建界面,点击 “新建”。
规则已经创建完成,现在发一条消息:
Topic: "t/1"
QoS: 0
Retained: false
Payload:
"{"host":"serverA","location":"roomA","internal":25,"external":37}"
然后检查 InfluxDB,新的 data point 是否添加成功:
$ docker exec -it influxdb influx
use db
Using database db
select * from "temperature"
name: temperature
time external host internal location
---- -------- ---- -------- --------
1561535778444457348 35 serverA 25 roomA
在规则列表里,可以看到刚才创建的规则的命中次数已经增加了 1: