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 等各類數據庫中供外部服務快速查詢或在服務宕機/客戶端 ...