全托管 MQTT 消息云服务 EMQX Cloud 可以为用户提供可靠、实时的物联网数据移动、处理和集成,助力加速物联网平台与应用开发。
其中,基于原有高性能内置规则引擎优化升级的「数据集成」模块,为用户配置处理及响应消息流与设备事件规则提供了一个清晰灵活的「可配置」架构解决方案,支持包括 Kafka、MySQL、Redis、Webhook 等在内的数十种数据集成资源,是 EMQX Cloud 帮助用户实现数据灵活处理与集成的利器。
在最近的版本更新中,EMQX Cloud 又新增了HStreamDB 和阿里云 Tablestore 两个外部数据库扩展支持。
功能详情
借助数据集成功能,用户可以根据自己的需求通过创建资源、创建规则、添加动作、测试运行这 4 个简单的步骤完成配置,实现设备数据的灵活运转。不仅极大简化了开发过程,降低了业务系统和 EMQX Cloud 之间的耦合程度,也为 EMQX Cloud 的私有功能定制提供了一个更优秀的基础架构。
EMQX Cloud 目前支持多种类型的数据队列、数据库及 Web 服务对接。本次新增的是分别由 EMQ 和阿里云开发的两款数据库。
HStreamDB
HStreamDB 是 EMQ 开源的一款专为流式数据设计的流数据库,可针对大规模实时数据流的接入、存储、处理、分发等环节进行全生命周期管理。它使用标准 SQL (及其流式拓展)作为主要接口语言,以实时性作为主要特征,旨在简化数据流的运维管理以及实时应用的开发。与 EMQX Cloud 集成后,用户可以轻松实现设备数据上云、处理与分发。
HStreamDB 配置界面
阿里云 Tablestore
阿里云表格存储(Tablestore)面向海量结构化数据提供 Serverless 表存储服务,同时针对物联网场景深度优化提供一站式的 IoTstore 解决方案。适用于海量账单、IM 消息、物联网、车联网、风控、推荐等场景中的结构化数据存储,提供海量数据低成本存储、毫秒级的在线数据查询和检索以及灵活的数据分析能力。
Tablestore 配置界面
数据集成操作指南
HStreamDB 数据集成参考文档:https://docs.emqx.com/zh/cloud/latest/rule_engine/rule_engine_save_hstreamdb.html
Tablestore 数据集成参考文档:https://docs.emqx.com/zh/cloud/latest/rule_engine/rule_engine_save_tablestore.html
注:1、本次更新资源在基础版不可用
2、对于专业版部署用户:请先完成 对等连接的创建,本文提到的 IP 均指资源的内网 IP。(专业版部署若开通 NAT 网关 也可使用公网 IP 连接资源)