原文:EMQ X 规则引擎系列(二)存储消息到 MySQL 数据库

场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息存储到 MySQL 数据库。为了便于后续分析检索,消息内容需要进行拆分存储。 该场景下设备端上报信息如下: 上报主题:cmd state :id,主题中 id 代表车辆客户端识别码 消息体: 当上报数据发动机转速数值大于 时,存储当前信息以便后续分析用户车辆使用情况。 准备工作 创建数据库 创建 iot data 数据库以存储消息数据, ...

2019-08-23 16:46 0 1281 推荐指数:

查看详情

EMQ X 规则引擎系列(七)存储消息到 MongoDB 数据库

MongoDB 介绍 非关系数据库(NoSQL) 用于超大规模数据存储,例如谷歌或 Facebook 每天为他们的用户收集万亿比特的数据。这些类型的数据存储不需要固定的模式,无需多余操作就可以横向扩展。 MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库 ...

Tue Oct 08 23:53:00 CST 2019 2 708
EMQ X 规则引擎系列(九)- 消息写入到 TDEngine

TDEngine 是什么 TDengine 是涛思数据(北京涛思数据科技有限公司)推出的一款开源的专为物联网、车联网、工业互联网、IT 运维等设计和优化的大数据平台。除核心的快 10 倍以上的时序数据库功能外,还提供缓存、数据订阅、流式计算等功能,最大程度减少研发和运维的复杂度 ...

Tue Oct 29 01:51:00 CST 2019 0 343
EMQ X 规则引擎系列 (八)桥接消息到 MQTT Broker

桥接概念 桥接是一种连接多个 EMQ X 或者其他 MQTT 消息中间件的方式。不同于集群,工作在桥接模式下的节点之间不会复制主题树和路由表。桥接模式所做的是: 按照规则消息转发至桥接节点; 从桥接节点订阅主题,并在收到消息后在本节点/集群中转发该消息。 工作在桥接模式下 ...

Fri Oct 18 17:20:00 CST 2019 0 572
EMQ X 规则引擎系列(一):数据桥接到消息队列(Kafka)

EMQ X 3.2 版本引入了 “规则引擎” 功能,支持在 EMQ X Broker 筛选终端上报的数据,处理后流至后端数据库或其他的消息队列。本篇以具体场景来说明 “如何使用规则引擎消息转发至 Kafka” 场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息桥接到 Kafka ...

Sat Aug 24 00:41:00 CST 2019 0 352
EMQ X + IoTDB:存储 MQTT 消息到时序数据库

IoTDB 是最早由清华大学发起的开源时序数据库项目,现已经是 Apache 的顶级项目。IoTDB 可以为用户提供数据收集、存储和分析等服务。由于其轻量级架构、高性能和高可用的特性,以及与 Hadoop 和 Spark 生态的无缝集成,满足了工业 IoT 领域中海量数据存储、高吞吐量数据写入 ...

Sun Jan 30 01:28:00 CST 2022 1 710
EMQ X规则引擎

简介 EMQ X Rule Engine (以下简称规则引擎) 用于配置 EMQ X 消息流与设备事件的处理、响应规则规则引擎不仅提供了清晰、灵活的 "配置式" 的业务集成方案,简化了业务开发流程,提升用户易用性,降低业务系统与 EMQ X 的耦合度;也为 EMQ X 的私有功能定制提供了一个 ...

Tue Aug 03 18:42:00 CST 2021 0 166
EMQ X 插件持久化系列 (五)MySQL MQTT 数据存储

本文以在 CentOS 7.2 中的实际例子来说明如何通过 MySQL存储相关的 MQTT 数据MySQL 属于传统的关系型数据库产品,其开放式的架构使得用户的选择性很强,而且随着技术的逐渐成熟,MySQL 支持的功能也越来越多,性能也在不断地提高,对平台的支持也在增多,此外,社区的开发 ...

Wed Jan 15 23:19:00 CST 2020 0 3906
MySQL数据库的事务及存储引擎

一、关系型数据库与非关系型数据库  1.关系型数据库的特点:   1)数据以表格的形式出现   2)每行为各种记录名称   3)每列为记录名称所对应的数据域   4)许多的行和列组成一张表单   5)若干的表单组成数据库  2.关系型数据库的优势:    2.1 复杂的查询:可以使 ...

Wed Oct 30 21:09:00 CST 2019 0 305
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM