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 支持的功能也越來越多，性能也在不斷地提高，對平台的支持也在增多，此外，社區的開發 ...