在万物互联的数字化浪潮中，海量设备连接与实时数据处理成为诸多企业面临的两大困扰。

EMQX 与 TDengine 作为物联网连接与大数据处理领域的领军产品，正在通过技术协同构建端到端的物联网/工业大数据解决方案。为工业互联网、车联网、能源管理、运维监控等诸多场景提供高效可靠的技术支撑。

EMQX：企业级 MQTT + AI 平台

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

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

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

强强联手，云端合作

作为核心合作伙伴， 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 ：

EMQX Cloud 配置操作步骤

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

前置准备

EMQX Cloud 专有版部署：需要在 EMQX Cloud 平台(https://cloud.emqx.com/)注册并创建 EMQX Cloud 专有版部署。(可免费体验)
TDengine Cloud 账户：需要在 TDengine Cloud 平台 (https://cloud.taosdata.com/) 注册并创建数据库实例。(可免费体验)
⽹络配置：需要为 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
);

6.在 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

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。

写在最后

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

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

ITPub博客

EMQX Cloud 、时序数据库 TDengine Cloud 实现数据互通！