EMQ X 规则引擎系列（一）：数据桥接到消息队列（Kafka）
EMQ X 3.2 版本引入了 “规则引擎” 功能，支持在 EMQ X Broker 筛选终端上报的数据，处理后流至后端数据库或其他的消息队列。本篇以具体场景来说明 “如何使用规则引擎将消息转发至 Kafka” 场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息桥接到 Kafka ...
原文：EMQ X 规则引擎系列 （八）桥接消息到 MQTT Broker
桥接概念 桥接是一种连接多个 EMQ X 或者其他 MQTT 消息中间件的方式。不同于集群，工作在桥接模式下的节点之间不会复制主题树和路由表。桥接模式所做的是： 按照规则把消息转发至桥接节点 从桥接节点订阅主题，并在收到消息后在本节点 集群中转发该消息。 工作在桥接模式下和工作在集群模式下有不同的应用场景，桥接可以完成一些单纯使用集群无法实现的功能： 跨 VPC 部署。由于桥接不需要复制主题树和路 ...
2019-10-18 09:20 0 572 推荐指数：
相关推荐
EMQ X 规则引擎系列（九）- 消息写入到 TDEngine
。 TDengine 作为时序处理引擎，可以完全不用 Kafka、HDFS/HBase/Spark、Redis 等软件 ...
EMQ X：规则引擎
简介 EMQ X Rule Engine (以下简称规则引擎) 用于配置 EMQ X 消息流与设备事件的处理、响应规则。规则引擎不仅提供了清晰、灵活的 "配置式" 的业务集成方案，简化了业务开发流程，提升用户易用性，降低业务系统与 EMQ X 的耦合度；也为 EMQ X 的私有功能定制提供了一个 ...
EMQ X 规则引擎系列（二）存储消息到 MySQL 数据库
场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息存储到 MySQL 数据库。为了便于后续分析检索，消息内容需要进行拆分存储。 该场景下设备端上报信息如下： 上报主题：cmd/state/:id，主题中 id 代表车辆客户端识别码 消息体： 当上 ...
EMQ X 规则引擎系列（七）存储消息到 MongoDB 数据库
MongoDB 介绍 非关系数据库（NoSQL） 用于超大规模数据的存储，例如谷歌或 Facebook 每天为他们的用户收集万亿比特的数据。这些类型的数据存储不需要固定的模式，无需多余操作就可 ...
EMQ X Enterprise (MQTT Broker) + Apache Kafka 构建高性能物联网消息处理后台
背景 在各类物联网项目中，设备产生的消息不仅仅作用于设备之间，还需要供业务系统使用以实现如安全审计、流量计费、数据统计、通知触发等功能，类似很容易通过以下原型系统完成： 该原型中需要在 EMQ X 上维护多个数据通道，以供每个业务环节按照各自需求从 EMQ X 中获取消息数据。这种解决方案 ...
EMQ X Broker 启动
以下的 shell 命令，都是在 emqx 的安装目录下进行的，因此需要先执行： 一、启停管理 启动 EMQ X Broker 停止 EMQ X Broker 1.1 启动失败 参考自 4.1.x 版本常见错误 我遇到了 EMQ X Broker v4.1.1 ...
EMQ X 插件持久化系列 （五）MySQL MQTT 数据存储
本文以在 CentOS 7.2 中的实际例子来说明如何通过 MySQL 来存储相关的 MQTT 数据。 MySQL 属于传统的关系型数据库产品，其开放式的架构使得用户的选择性很强，而且随着技术的逐渐成熟，MySQL 支持的功能也越来越多，性能也在不断地提高，对平台的支持也在增多，此外，社区的开发 ...