保存数据到 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...相关推荐

  1. mysql t 保存_检查 (调试) - 离线消息保存到 MySQL - 《EMQ X Enterprise v4.1 中文文档》 - 书栈网 · BookStack...

    离线消息保存到 MySQL 搭建 MySQL 数据库,并设置用户名密码为 root/public,以 MacOS X 为例: $ brew install mysql $ brew services ...

  2. emqtt数据存储mysql,数据存储 - MongoDB 消息存储 - 《EMQ X Enterprise v3.0 中文文档》 - 书栈网 · BookStack...

    MongoDB 消息存储 配置 MongoDB 消息存储 配置文件: emqx_backend_mongo.conf 配置 MongoDB 服务器 支持配置多台 MongoDB 服务器连接池:## M ...

  3. mysql集群跨地域同步部署_跨地域冗余 - 跨数据中心部署方案 - 《TiDB v2.1 用户文档》 - 书栈网 · BookStack...

    跨数据中心部署方案 作为 NewSQL 数据库,TiDB 兼顾了传统关系型数据库的优秀特性以及 NoSQL 数据库可扩展性,以及跨数据中心(下文简称"中心")场景下的高可用.本文档 ...

  4. mysql pmod项目_内置函数 - 数学函数 - 《Apache Doris 文档(201812)》 - 书栈网 · BookStack...

    数学函数 abs(double a) 功能: 返回参数的绝对值 返回类型:double类型 使用说明:使用该函数需要确保函数的返回值是整数. acos(double a) 功能: 返回参数的反余弦值 ...

  5. typeorm mysql2_指南 - 使用 TypeORM 和 Express 的示例 - 《TypeORM v0.2.20 中文文档》 - 书栈网 · BookStack...

    使用 TypeORM 和 Express 的示例 初始设置 让我们创建一个名为"user"的简单应用程序,它将用户存储在数据库中 并允许我们在 web api 创建.更新.删除和获 ...

  6. mysql 中间件 租户管理_多租户的设计与实现 - 《Gaea - MySQL 中间件》 - 书栈网 · BookStack...

    多租户的设计与实现 背景 gaea多租户是为了实现一套gaea集群,可以接入多个业务系统的不同数据库,方便部署.运维.gaea多租户为软多租户,一个租户称为一个namespace,多个namespac ...

  7. bs4爬取的时候有两个标签相同_PYTHON爬取数据储存到excel

    PYTHON爬取数据储存到excel 大家周末好呀,我是滑稽君.前两天上网课时朋友发来消息说需要爬取一些数据,然后储存到excel里.记得我公众号里发过关于爬虫的文章,所以找我帮个忙.于是滑稽君花时间 ...

  8. beautifulsoup爬取网页中的表格_PYTHON爬取数据储存到excel

    PYTHON爬取数据储存到excel 大家周末好呀,我是滑稽君.前两天上网课时朋友发来消息说需要爬取一些数据,然后储存到excel里.记得我公众号里发过关于爬虫的文章,所以找我帮个忙.于是滑稽君花时间 ...

  9. mysql数据库引擎博客_2、MySQL常见数据库引擎及比较?

    摘自: https://www.cnblogs.com/zhuifeng-mayi/p/9265075.html MySQL存储引擎简介 MySQL支持数个存储引擎作为对不同表的类型的处理器.MySQ ...

最新文章

  1. php把单词切割成数组,PHP – 将单词分解为数组
  2. 删除表中存在多条相同记录的方法
  3. 十七、Redis事务
  4. 中国移动领取买卖将在2016年破万亿
  5. PHP各个组件或工具的安装与使用
  6. 一个word文档中,多个表格的批量调整(根据窗口调整表格和添加表格水平线)...
  7. BugKuCTF WEB 网站被黑
  8. php中tables,php显示TABLE数据
  9. mysql行级锁升级_mysql innodb 行级锁升级
  10. 8266获取网络时间
  11. 飞秋下载2010正式版_飞秋下载
  12. 转换到bot模式失败_《认知觉醒》:为什么越“努力”,会越失败
  13. JQuery点击收起,点击展开以及部分非空小验证
  14. 细谈会话管理-----Cookie和Session
  15. 机器学习必学十大算法
  16. 邮箱被国际反垃圾邮件组织拉黑的解决方法
  17. introduction
  18. “MPX4115型压力传感器+PCF8591型AD+模拟IIC总线”的Proteus仿真
  19. java.lang.NoClassDefFoundError: org/codehaus/plexus/compiler/manager/NoSuchCompilerException
  20. 如何处理训练样本不均衡的问题

热门文章

  1. php 合计,表格怎么合计总数
  2. 导数与微分的知识点思维导图_高中物理思维导图,高中三年知识点一个不漏
  3. java程序包r不存在_java - 从命令行使用Gradle构建时,“程序包R不存在”错误 - 堆栈内存溢出...
  4. ant里面table嵌套子表格_ElementUI el-table行内编辑验证,动态增减行
  5. dubbo 自定义路由_高性能可扩展分布式RPC框架Dubbo内核原理揭秘
  6. 25岁!零基础想转行做软件测试,可以吗?晚是不晚!
  7. 新鲜角度看问题:从Python角度解析Selenium原理
  8. 一线城市BAT名企软件测试职位解析,有什么样的技术要求?
  9. oracle 认证考试题目,Oracle OCP 19c 认证1Z0-082考试题库(第1题)
  10. 下载文件扩展名php,[宜配屋]听图阁