保存数据到 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 (opens new window)，选择左侧的 “规则” 选项卡。

选择触发事件 “消息发布”，然后填写规则 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: