Webinar
让 AI Agents 协同工作：探索 A2A over MQTT 与 EMQX A2A Registry｜立即报名 →
下载试用

EMQX 时序数据库集成

将 MQTT 数据流式传输到 时序数据库

使用 EMQX 采集 MQTT 遥测数据，通过 SQL 规则完成预处理，再写入数据库，用于分析和可视化。

下载 EMQX 企业版数据库选型指南

概览

为什么选择 EMQX 处理时序数据？

由 EMQX 负责设备连接和数据预处理，让数据库专注于存储和查询。

灵活扩展设备连接

通过 EMQX 连接 MQTT 设备，将遥测数据路由到数据库，并根据连接数和数据量规划各环节的容量。

降低数据库负载

在存储前过滤和转换遥测数据，让数据库只处理应用真正需要的数据。

自由选择数据库

通过 EMQX 数据集成将遥测数据路由到所支持的数据库，存储层可以独立演进，不受设备连接的影响。

架构

MQTT 与时序数据库集成架构

MQTT 设备将数据发布到 EMQX，EMQX 预处理遥测数据后，写入已配置的数据库 Sink。

工作原理

三步实现从传感器到数据库的数据流转

在 Flow 设计器中配置从 MQTT 主题到数据库写入的完整数据流。

开始之前

  • 支持所选数据库集成的 EMQX 环境。
  • EMQX 可访问的数据库端点。
  • 具备目标表、存储桶或集合写入权限的凭据。
  1. 1

    连接设备

    将传感器等设备连接到 EMQX，并将遥测数据发布到 MQTT 主题。

  2. 2

    预处理数据

    使用 SQL 规则过滤消息，映射时间戳、测量值和字段类型。

  3. 3

    写入数据库

    通过数据库 Sink 写入一条测试消息，检查时间戳、字段类型和存储值。

核心能力

专为时序数据打造

连接设备、转换 MQTT 数据、监控数据库写入。

支持 MQTT 5.0

设备可通过 MQTT 5.0 或 3.1.1 接入，协议支持与所选数据库无关。

MQTT 协议指南

缓冲与重试

借助缓冲和重试选项应对临时中断，并可根据业务负载设置缓冲模式、容量和请求超期时间。

缓冲队列指南

实时数据转换

在写入数据库之前，使用内置 SQL 规则过滤消息、提取测量值、转换字段值。

规则 SQL 参考

灵活的写入模式

在支持的场景下选择同步或异步请求，并根据吞吐量和延迟要求调整写入设置。

Sink 功能指南

数据分析就绪

将预处理后的遥测数据存入数据库，使用现有工具进行查询、构建仪表盘和分析。

TimescaleDB 集成指南

数据流监控

跟踪成功、失败和丢弃的请求以及队列深度，及时发现数据投递问题。

数据投递监控指南

生态

连接您的时序数据生态

将 MQTT 遥测数据接入您的存储平台，并使用 Prometheus 监控 EMQX。

资源

探索 MQTT 与时序数据库集成

FAQ

常见问题

构建 MQTT 到时序数据库的数据链路

与 EMQX 专家一起规划数据库集成、数据预处理和部署方案。

联系专家下载 EMQX 企业版