emq数据储存到mysql,规则引擎示例 - 保存数据到 MySQL - 《EMQ X Enterprise v4.0 中文文档》 - 书栈网 · BookStack...
保存数据到 MySQL
搭建 MySQL 数据库,并设置用户名密码为 root/public,以 MacOS X 为例:$ brew install mysql
$ brew services start mysql
$ mysql-u root-h localhost-p
ALTER USER'root'@'localhost'IDENTIFIED BY'public';
初始化 MySQL 表:$ mysql-u root-h localhost-ppublic
创建 “test” 数据库:CREATE DATABASE test;
创建 t_mqtt_msg 表:USE test;
CREATE TABLE`t_mqtt_msg`(
`id`int(11)unsignedNOT NULL AUTO_INCREMENT,
`msgid`varchar(64)DEFAULT NULL,
`topic`varchar(255)NOT NULL,
`qos`tinyint(1)NOT NULL DEFAULT'0',
`payload`blob,
`arrived`datetime NOT NULL,
PRIMARY KEY(`id`),
INDEX topic_index(`id`,`topic`)
)ENGINE=InnoDBDEFAULT CHARSET=utf8MB4;
创建规则:
选择触发事件 “消息发布”,然后填写规则 SQL:SELECT*FROM"#"
关联动作:
在 “响应动作” 界面选择 “添加”,然后在 “动作” 下拉框里选择 “保存数据到 MySQL”。
填写动作参数:
“保存数据到 MySQL” 动作需要两个参数:
1). SQL 模板。这个例子里我们向 MySQL 插入一条数据,SQL 模板为:insertintot_mqtt_msg(msgid,topic,qos,payload,arrived)values(${id},${topic},${qos},${payload},FROM_UNIXTIME(${timestamp}/1000))
2). 关联资源的 ID。现在资源下拉框为空,可以点击右上角的 “新建资源” 来创建一个 MySQL 资源:
选择 “MySQL 资源”。
填写资源配置:
数据库名填写 “test”,用户名填写 “root”,密码填写 “publish”,备注为 “MySQL resource to 127.0.0.1:3306 db=test”
点击 “新建” 按钮。
返回响应动作界面,点击 “确认”。
返回规则创建界面,点击 “新建”。
在规则列表里,点击 “查看” 按钮或规则 ID 连接,可以预览刚才创建的规则:
规则已经创建完成,现在发一条数据:Topic:"t/a"
QoS:1
Payload:"hello"
然后检查 MySQL 表,新的 record 是否添加成功:
emq数据储存到mysql,规则引擎示例 - 保存数据到 MySQL - 《EMQ X Enterprise v4.0 中文文档》 - 书栈网 · BookStack...相关推荐
- mysql t 保存_检查 (调试) - 离线消息保存到 MySQL - 《EMQ X Enterprise v4.1 中文文档》 - 书栈网 · BookStack...
离线消息保存到 MySQL 搭建 MySQL 数据库,并设置用户名密码为 root/public,以 MacOS X 为例: $ brew install mysql $ brew services ...
- emqtt数据存储mysql,数据存储 - MongoDB 消息存储 - 《EMQ X Enterprise v3.0 中文文档》 - 书栈网 · BookStack...
MongoDB 消息存储 配置 MongoDB 消息存储 配置文件: emqx_backend_mongo.conf 配置 MongoDB 服务器 支持配置多台 MongoDB 服务器连接池:## M ...
- mysql集群跨地域同步部署_跨地域冗余 - 跨数据中心部署方案 - 《TiDB v2.1 用户文档》 - 书栈网 · BookStack...
跨数据中心部署方案 作为 NewSQL 数据库,TiDB 兼顾了传统关系型数据库的优秀特性以及 NoSQL 数据库可扩展性,以及跨数据中心(下文简称"中心")场景下的高可用.本文档 ...
- mysql pmod项目_内置函数 - 数学函数 - 《Apache Doris 文档(201812)》 - 书栈网 · BookStack...
数学函数 abs(double a) 功能: 返回参数的绝对值 返回类型:double类型 使用说明:使用该函数需要确保函数的返回值是整数. acos(double a) 功能: 返回参数的反余弦值 ...
- typeorm mysql2_指南 - 使用 TypeORM 和 Express 的示例 - 《TypeORM v0.2.20 中文文档》 - 书栈网 · BookStack...
使用 TypeORM 和 Express 的示例 初始设置 让我们创建一个名为"user"的简单应用程序,它将用户存储在数据库中 并允许我们在 web api 创建.更新.删除和获 ...
- mysql 中间件 租户管理_多租户的设计与实现 - 《Gaea - MySQL 中间件》 - 书栈网 · BookStack...
多租户的设计与实现 背景 gaea多租户是为了实现一套gaea集群,可以接入多个业务系统的不同数据库,方便部署.运维.gaea多租户为软多租户,一个租户称为一个namespace,多个namespac ...
- bs4爬取的时候有两个标签相同_PYTHON爬取数据储存到excel
PYTHON爬取数据储存到excel 大家周末好呀,我是滑稽君.前两天上网课时朋友发来消息说需要爬取一些数据,然后储存到excel里.记得我公众号里发过关于爬虫的文章,所以找我帮个忙.于是滑稽君花时间 ...
- beautifulsoup爬取网页中的表格_PYTHON爬取数据储存到excel
PYTHON爬取数据储存到excel 大家周末好呀,我是滑稽君.前两天上网课时朋友发来消息说需要爬取一些数据,然后储存到excel里.记得我公众号里发过关于爬虫的文章,所以找我帮个忙.于是滑稽君花时间 ...
- mysql数据库引擎博客_2、MySQL常见数据库引擎及比较?
摘自: https://www.cnblogs.com/zhuifeng-mayi/p/9265075.html MySQL存储引擎简介 MySQL支持数个存储引擎作为对不同表的类型的处理器.MySQ ...
最新文章
- php把单词切割成数组,PHP – 将单词分解为数组
- 删除表中存在多条相同记录的方法
- 十七、Redis事务
- 中国移动领取买卖将在2016年破万亿
- PHP各个组件或工具的安装与使用
- 一个word文档中,多个表格的批量调整(根据窗口调整表格和添加表格水平线)...
- BugKuCTF WEB 网站被黑
- php中tables,php显示TABLE数据
- mysql行级锁升级_mysql innodb 行级锁升级
- 8266获取网络时间
- 飞秋下载2010正式版_飞秋下载
- 转换到bot模式失败_《认知觉醒》:为什么越“努力”,会越失败
- JQuery点击收起,点击展开以及部分非空小验证
- 细谈会话管理-----Cookie和Session
- 机器学习必学十大算法
- 邮箱被国际反垃圾邮件组织拉黑的解决方法
- introduction
- “MPX4115型压力传感器+PCF8591型AD+模拟IIC总线”的Proteus仿真
- java.lang.NoClassDefFoundError: org/codehaus/plexus/compiler/manager/NoSuchCompilerException
- 如何处理训练样本不均衡的问题
热门文章
- php 合计,表格怎么合计总数
- 导数与微分的知识点思维导图_高中物理思维导图,高中三年知识点一个不漏
- java程序包r不存在_java - 从命令行使用Gradle构建时,“程序包R不存在”错误 - 堆栈内存溢出...
- ant里面table嵌套子表格_ElementUI el-table行内编辑验证,动态增减行
- dubbo 自定义路由_高性能可扩展分布式RPC框架Dubbo内核原理揭秘
- 25岁!零基础想转行做软件测试,可以吗?晚是不晚!
- 新鲜角度看问题:从Python角度解析Selenium原理
- 一线城市BAT名企软件测试职位解析,有什么样的技术要求?
- oracle 认证考试题目,Oracle OCP 19c 认证1Z0-082考试题库(第1题)
- 下载文件扩展名php,[宜配屋]听图阁