EMQX + TDengine 实现云端数据互通！联手打造物联网、工业大数据解决方案

1

EMQX：企业级 MQTT + AI 平台

EMQX 是一款云原生分布式 MQTT 接入平台，兼容多种消息传输协议，具备高可用性和扩展性，单节点支持 500 万 MQTT 连接，能够处理大规模并发消息传输，并提供端到端数据加密和细粒度访问控制功能，充分利用数据价值的同时，全面满足企业数据的合规性需求，为物联网（IoT）和人工智能应用提供可靠的实时消息传输和设备连接解决方案。

2

TDengine：企业级时序大数据平台

TDengine 是一款专为物联网、工业互联网等场景设计并优化的大数据平台，其核心模块是高性能、集群开源、云原生、极简的时序数据库。它能安全高效地将大量设备每天产生的高达 TB 甚至 PB 级的数据进行汇聚、存储、分析和分发，并提供 AI 智能体对数据进行预测与异常检测，提供实时的商业洞察。

3

强强联手，云端合作

作为核心合作伙伴，TDengine 与 EMQX 的私有化部署早已完成深度生态适配。在 SaaS 领域，双方合作再进一步：TDengine Cloud 此前已全面支持 MQTT 数据源接入，实现与 EMQX/EMQX Cloud 时序数据的无缝对接。最新发布的 EMQX Cloud 5.2.13 版本内置了 TDengine Cloud 原生连接器，补齐了双方数据交互的最后一个环节。  该原生连接器的主要优势为：

• 简化配置流程：这⼀功能显著简化了时序数据接入 TDengine 的流程，使⽤户⽆需再通过繁琐的 HTTP 连接器配置过程，只需在图形化界面进行简单的配置就可以连接两⼤云服务平台，为业务轻松赋能。

• 原⽣协议⽀持：直接使⽤ TDengine Cloud 的原⽣协议传输数据，避免了 HTTP 连接的额外开销，提升了性能与稳定性。

• ⾼性能数据传输：优化的数据传输机制，确保物联⽹数据能够快速可靠地存储到 TDengine Cloud。

• 灵活的数据处理：强⼤的规则引擎⽀持，可根据业务需求对数据进⾏筛选、转换和处理。

• ⼀站式配置：⽆需分别管理 EMQX 和 TDengine 的连接参数，统⼀在 EMQX Cloud 控制台完成所有配置。

• 可视化监控：集成的数据流监控功能，轻松了解数据流转状态与性能指标。

接下来，我们向大家介绍如何使用该连接器实现 MQTT 数据接入 TDengine Cloud。

4

EMQX Cloud  配置操作步骤 

以下是配置 EMQX Cloud 与 TDengine Cloud 原⽣连接的详细步骤指南：

前置准备

1. EMQX Cloud 专有版部署：需要在 EMQX Cloud 平台（https://cloud.emqx.com/）注册并创建 EMQX Cloud 专有版部署 。（可免费体验）

2. TDengine Cloud 账户：需要在 TDengine Cloud 平台 (https://cloud.taosdata.com/) 注册并创建数据库实例。（可免费体验）

3. ⽹络配置：需要为 EMQX Cloud 专有版部署开通 NAT ⽹关，允许 EMQX Cloud 部署通过公⽹访问 TDengine Cloud 实例。

步骤1：TDengine Cloud 准备⼯作 

• 登录 TDengine Cloud 控制台 (https://cloud.taosdata.com/)

• 创建并部署 TDengine Cloud 服务实例

• 进⼊实例后，在左侧菜单栏中点击"数据浏览器"

• 创建数据库，例如 "iot_data"

• 在数据库中创建表：

CREATE TABLE iot_data.temp_hum ( 
 ts TIMESTAMP, 
 clientid NCHAR(256), 
 temp FLOAT,
 hum FLOAT 
); 

• 在 TDengine Cloud 控制台获取连接 URL 和访问令牌：TDENGINE_CLOUD_URL、TDENGINE_CLOUD_TOKEN的值以备后⽤。

步骤2：在EMQX Cloud创建TDengine

1. 登录 EMQX Cloud 控制台

2. 在部署菜单中选择"数据集成"，在数据持久化分类下选择 TDengine

3. 点击"新建连接器"，填写以下信息：

• 连接器名称：为连接器指定⼀个名称，如 "TDengine Cloud"

• 主机列表：填写 TDengine Cloud 提供的连接  （TDENGINE_CLOUD_URL的值）

• Token：填⼊从 TDengine Cloud 获取的访问令牌 （TDENGINE_CLOUD_TOKEN的值）

• 根据需要配置⾼级设置（可选）

4. 点击"测试连接"按钮验证连接状态，成功后会显示"连接器可⽤"提示 。

5. 点击"新建"按钮完成连接器的创建

步骤3：创建数据集成规则  

1. 点击刚创建的连接器列表中"操作"列下的"新建规则"图标，或在"规则列表"中点击"新建规则"

2. 在 SQL 编辑器中输⼊规则，定义需要处理的消息，例如：

SELECT 
 now_timestamp('millisecond') as ts, 
 payload.temp as temp, 
 payload.hum as hum, 
 clientid 
FROM 
"devices/temp_hum" 

3. 点击"SQL示例"和"启⽤调试"按钮可以学习和测试规则 SQL 的结果（可选）

4. 点击"下⼀步"开始创建动作 ：

步骤4：配置动作 

1. 从"使⽤连接器"下拉框中选择您刚才创建的 TDengine 连接器

2. 数据库名字：填写在 TDengine Cloud 中创建的数据库名称，如 "iot_data"

3. 配置SQL模板，⽤于将数据写⼊TDengine Cloud：

INSERT INTO iot_data.temp_hum(ts, temp, hum, clientid) VALUES (${ts}, ${temp}, ${hum}, '${clientid}') 

4. 启⽤"未定义变量作为 NULL"选项，确保规则引擎在变量未定义时能正确处理 。

5. 根据业务需求配置⾼级选项，如同步/异步模式、批量参数等。（可选）

注：对消息延迟不敏感（延迟⼩于1s）的情况，可以将最⼤批量请求⼤⼩从 1 修改为 100，从⽽提⾼写⼊性能。

6. 点击"确认"按钮完成动作配置

7. 在弹出的"成功创建规则"提示框中点击"返回规则列表"，完成整个数据集成配置。

步骤5：模拟数据上报

1. 在 EMQX Cloud 部署菜单中选择”在线调试“，并点击连接 。

2. 订阅主题 devices/temp_hum 。

3. 向主题 devices/temp_hum 发送温湿度数据 ：{"temp": 23, "hum": 90}

步骤6：在TDengine Cloud查询上报数据  

1. 访问 TDengine Cloud 数据浏览器 。

2. 查询上报数据结果 。

SELECT * from iot_data7.temp_hum;

可以看到，数据已经经由 EMQX Cloud 写入了 TDengine Cloud 当中。

关于TDengine Cloud 连接器更具体的使用，可以参考：https://docs.emqx.com/zh/cloud/latest/data_integration/tdengine_cloud.html

5

TDengine Cloud 配置操作步骤

关于 TDengine Cloud 一侧，同样可以通过部署 MQTT 数据源实现对 EMQX Cloud 的数据接入，具体操作参考 TDengine 官方文档：https://docs.taosdata.com/cloud/data-in/ds/mqtt/，以及该博客：https://www.taosdata.com/tdengine-engineering/27256.html。

、6

写在最后

目前， EMQX Cloud 只支持通过公网将数据接入 TDengine Cloud 当中，后续还会更新以支持私有连接（private link）方式，进一步提升 EMQX Cloud 和 TDengine Cloud 用户的使用体验。

面对数据洪流的挑战与机遇，EMQX 与 TDengine 的深度合作为行业带来了突破性的技术解决方案。不仅构建了支撑海量数据处理的超高性能技术底座，更通过创新性的架构设计，重塑工业互联网与物联网的数据基础设施标准范式，助力企业在数智化转型浪潮中获得关键竞争优势，开启智能化发展的新篇章。