EMQX Cloud & TDengine Cloud 实现数据互通！联手打造端到端云上大数据解决方案

作为核心合作伙伴，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 控制台完成所有配置。

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

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

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

• 连接器名称：为连接器指定⼀个名称，如：TDengine Cloud。
• 主机列表：填写 TDengine Cloud 提供的连接（TDENGINE_CLOUD_URL的值）。
• Token：填⼊从 TDengine Cloud 获取的访问令牌（TDENGINE_CLOUD_TOKEN的值）。
• 根据需要配置⾼级设置（可选）。

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

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

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 一侧，同样可以通过部署 MQTT 数据源实现对 EMQX Cloud 的数据接入，具体操作参考 TDengine 官方文档：https://docs.taosdata.com/cloud/data-in/ds/mqtt/

以及该博客：https://www.taosdata.com/tdengine-engineering/27256.html