共计 2554 个字符，预计需要花费 7 分钟才能阅读完成。
场景介绍
该场景须要将 EMQ X 指定主题下且满足条件的音讯存储到 Reids。为了便于后续剖析检索，音讯内容须要进行拆分存储。
该场景下设施端上报信息如下：
- 上报主题：
cmd/state/:id，主题中 id 代表车辆客户端识别码 -
音讯体：
{ "id": "NXP-058659730253-963945118132721-22", // 客户端识别码 "speed": 32.12, // 车辆速度 "direction": 198.33212, // 行驶方向 "tachometer": 3211, // 发动机转速，数值大于 8000 时才需存储 "dynamical": 8.93, // 刹时油耗 "location": { // GPS 经纬度数据 "lng": 116.296011, "lat": 40.005091 }, "ts": 1563268202 // 上报工夫 }
当上报数据发动机转速数值大于 8000 时，存储以后信息以便后续剖析用户车辆应用状况。
DashBoard 配置
创立资源
关上 EMQ X Dashboard，进入左侧菜单的 资源 页面，点击 新建 按钮，键入 Redis 服务器信息进行资源创立【点击测试连贯能够测试配置是否正确】。
创立规定
进入左侧菜单的 规定 页面，点击 新建 按钮，进行规定创立。界面如下：
- 筛选所需字段
规定引擎应用 SQL 语句解决规定条件，该业务中咱们须要将 payload 中所有字段独自抉择进去，应用 payload.fieldName 格局进行抉择，还须要音讯上下文的 topic、qos、id 信息，以后 SQL 如下：
SELECT
payload.id AS client_id,
payload.speed AS speed,
payload.tachometer AS tachometer,
payload.ts AS ts,
id
FROM
"#"- 确立筛选条件
应用 SQL 语句 WHERE 字句进行条件筛选，该业务中咱们须要定义两个条件：
- 仅解决
cmd/state/:id主题，应用主题通配符=~对topic进行筛选：topic =~ 'cmd/state/+' - 仅解决
tachometer > 8000的音讯，应用比拟符对tachometer进行筛选：payload.tachometer > 8000
组合上一步骤失去 SQL 如下：
SELECT
payload.id AS client_id,
payload.speed AS speed,
payload.tachometer AS tachometer,
payload.ts AS ts,
id
FROM
"#"
WHERE
topic =~ 'cmd/state/+'
AND payload.tachometer > 8000- 应用 SQL 测试性能进行输入测试
借助 SQL 测试性能，咱们能够实时查看以后 SQL 解决后的数据输入，该性能须要咱们指定 payload 等模仿原始数据。
payload 数据如下，留神更改 tachometer 数值大小，以满足 SQL 条件：
{
"id": "NXP-058659730253-963945118132721-22",
"speed": 32.12,
"direction": 198.33212,
"tachometer": 9001,
"dynamical": 8.93,
"location": {
"lng": 116.296011,
"lat": 40.005091
},
"ts": 1563268202
}点击 SQL 测试 切换按钮，更改 topic 与 payload 为场景中的信息，点击 测试 按钮查看数据输入
测试输入数据为：
{
"ts": 1563268202,
"tachometer": 9001,
"speed": 32.12,
"id": "5B4499F88C2C0F443000013AD0000",
"client_id": "NXP-058659730253-963945118132721-22"
}测试输入与预期相符，咱们能够进行后续步骤。
增加响应动作，存储音讯到 Redis
SQL 条件输入输出无误后，咱们持续增加相应动作，配置写入 SQL 语句，将筛选后果存储到 Redis。
点击响应动作中的 增加 按钮，抉择 保留数据到 Redis 动作，选取刚刚选定的资源，咱们应用 ${fieldName} 语法填充 SQL 语句，将数据插入到数据库，最初点击 新建 按钮实现规定创立。
动作的 SQL 配置如下：
HMSET test client_id "${client_id}" speed "${speed}" tachometer "${tachometer}" ts "${ts}" msg_id "${msg_id}"应用 Redis 的哈希表构造，以 message id 为表明创立哈希表
点击确认后能够看到有一条新规定创立胜利
测试
预期后果
咱们胜利创立了一条规定，蕴含一个解决动作，动作冀望成果如下：
- 设施向
cmd/state/:id主题上报音讯时，当音讯中的tachometer数值超过 8000 时将命中 SQL，规定列表中 已命中 数字减少 1； - Redis 将减少一个以以后 message id 命名的哈希表，数值与以后音讯统一。
应用 Dashboard 中的 Websocket 工具测试
切换到 工具 –> Websocket 页面，应用任意信息客户端连贯到 EMQ X，连贯胜利后在 音讯 卡片发送如下信息：
- 主题：cmd/state/NXP-058659730253-963945118132721-22
-
音讯体：
{ "id": "NXP-058659730253-963945118132721-22", "speed": 32.12, "direction": 198.33212, "tachometer": 8081, "dynamical": 8.93, "location": { "lng": 116.296011, "lat": 40.005091 }, "ts": 1563268202 }
点击 发送 按钮，查看失去以后规定已命中统计值为 1。
Redis 命令行中查看哈希表获取单个列命令：
hget ${key} ${field}, 例：hget test speed,hget test tachometer获取所有列命令：
HGETALL ${key}, 例：HGETALL test
记录失去数据如下：
至此，咱们通过规定引擎实现了应用规定引擎存储音讯到 Reids 的业务开发。
【参考文档】EMQ 官网链接：EMQ 官网 返回上一级EMQ X 数据长久化 存储音讯到 Redis
