EMQ X 规则引擎系列 （八）桥接消息到 MQTT Broker
桥接概念 桥接是一种连接多个 EMQ X 或者其他 MQTT 消息中间件的方式。不同于集群，工作在桥接模式下的节点之间不会复制主题树和路由表。桥接模式所做的是： 按照规则把消息转发至桥接节点； 从桥接节点订阅主题，并在收到消息后在本节点/集群中转发该消息。 工作在桥接模式下 ...
原文：EMQ X 规则引擎系列（一）：数据桥接到消息队列（Kafka）
EMQ X . 版本引入了 规则引擎 功能，支持在 EMQ X Broker 筛选终端上报的数据，处理后流至后端数据库或其他的消息队列。本篇以具体场景来说明 如何使用规则引擎将消息转发至 Kafka 场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息桥接到 Kafka 。为了便于后续分析检索，消息内容需要进行拆分。 该场景下设备端上报信息如下： 上报主题：cmd state :id，主 ...
2019-08-23 16:41 0 352 推荐指数：
相关推荐
EMQ X 规则引擎系列（九）- 消息写入到 TDEngine
。 TDengine 作为时序处理引擎，可以完全不用 Kafka、HDFS/HBase/Spark、Redis 等软件 ...
EMQ X 规则引擎系列（二）存储消息到 MySQL 数据库
场景介绍 该场景需要将 EMQ X 指定主题下且满足条件的消息存储到 MySQL 数据库。为了便于后续分析检索，消息内容需要进行拆分存储。 该场景下设备端上报信息如下： 上报主题：cmd/state/:id，主题中 id 代表车辆客户端识别码 消息体： 当上报数据 ...
EMQ X 规则引擎系列（七）存储消息到 MongoDB 数据库
MongoDB 介绍 非关系数据库（NoSQL） 用于超大规模数据的存储，例如谷歌或 Facebook 每天为他们的用户收集万亿比特的数据。这些类型的数据存储不需要固定的模式，无需多余操作就可以横向扩展。 MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据 ...
EMQ X：规则引擎
简介 EMQ X Rule Engine (以下简称规则引擎) 用于配置 EMQ X 消息流与设备事件的处理、响应规则。规则引擎不仅提供了清晰、灵活的 "配置式" 的业务集成方案，简化了业务开发流程，提升用户易用性，降低业务系统与 EMQ X 的耦合度；也为 EMQ X 的私有功能定制提供了一个 ...
Mosquitto 到 EMQ X 集群的桥接
EMQ X 节点可以被其他类型的 MQTT 消息中间件桥接，实现跨平台的消息订阅和发送。本文我们以一个配置实例来说明如何配置 Mosquitto 到 EMQ X 的桥接。 Mosquitto 是一个小型轻量的开源 MQTT Broker，由 C/C++ 语言编写。Mosquitto 采用单核心 ...
EMQ消息队列初体验
使用命令创建admin用户，密码123 配置规则/etc/emqx/acl.conf（除管理员，其他用户只能订阅限定的测试主题路径） ...
EMQ X 插件持久化系列 （三）EMQ X Redis 数据持久化
EMQ X 数据持久化简介 数据持久化的主要使用场景包括将客户端上下线状态，订阅主题信息，消息内容，消息抵达后发送消息回执等操作记录到 Redis、MySQL、PostgreSQL、MongoDB、Cassandra、AWS DynamoDB 等各类数据库中供外部服务快速查询或在服务宕机/客户端 ...