在萬物互聯的數字化浪潮中，海量設備連接與實時數據處理成為諸(zhu)多企(qi)業面臨(lin)的兩大困(kun)擾。

EMQX 與 TDengine 作(zuo)為物(wu)聯(lian)(lian)網連接與大(da)數據處理領域的領軍(jun)產品，正在(zai)通過(guo)技(ji)(ji)術(shu)協(xie)同構建端(duan)到端(duan)的物(wu)聯(lian)(lian)網/工業大(da)數據解決(jue)方案。為工業互聯(lian)(lian)網、車(che)聯(lian)(lian)網、能(neng)源管理、運(yun)維(wei)監控等諸多場景(jing)提供高效可靠(kao)的技(ji)(ji)術(shu)支撐。

EMQX：企業級 MQTT + AI 平臺

EMQX 是一款云原生分布式 MQTT 接入平臺，兼容多種消息傳輸協議，具備高可用性和擴展性，單節點支持 500 萬 MQTT 連接，能夠處理大規模并發消息傳輸，并提供端到端數據(ju)(ju)加密和細粒(li)度訪問控制功能(neng)，充分利用(yong)(yong)數(shu)據(ju)(ju)價(jia)值的同時，全面滿足企業數(shu)據(ju)(ju)的合(he)規性需求，為(wei)物聯網（IoT）和人工智能(neng)應用(yong)(yong)提供可靠的實時消(xiao)息傳輸和設備連接解(jie)決(jue)方案。

TDengine：企業級時序大數據平臺

TDengine 是一款專為物聯網、工業互聯網等場景設計并優化的大數據平臺，其核心模塊是高性能、集群開源、云原生、極簡的時序數據庫。它能安全高效地將大量設備每天產生的高達 TB 甚至 PB 級的數據進行匯聚、存儲、分析和分發，并提供AI 智能體對數(shu)據(ju)進行預測與異常檢測，提(ti)供實(shi)時的商業洞察(cha)。

強強聯手，云端合作

作(zuo)為(wei)核心合作(zuo)伙伴(ban)，TDengine 與 EMQX 的私有化部署(shu)早已完(wan)成深度生態適配。在 SaaS 領域(yu)，雙方合作(zuo)再進一步：TDengine Cloud 此前已全面(mian)支持 MQTT 數(shu)據(ju)源接(jie)(jie)入，實(shi)現與 EMQX/EMQX Cloud 時(shi)序數(shu)據(ju)的無縫對接(jie)(jie)。最新發(fa)布的 EMQX Cloud 5.2.13 版本內置(zhi)了 TDengine Cloud 原生連接(jie)(jie)器(qi)，補(bu)齊了雙方數(shu)據(ju)交(jiao)互的最后一個環節。 該原生連接(jie)(jie)器(qi)的主要(yao)優勢為(wei)：

簡(jian)化配(pei)置(zhi)流程(cheng)：這?功能顯著簡(jian)化了(le)時序數(shu)據接(jie)(jie)入 TDengine 的流程(cheng)，使(shi)?戶?需再(zai)通(tong)過繁(fan)瑣的 HTTP 連(lian)接(jie)(jie)器配(pei)置(zhi)過程(cheng)，只(zhi)需在圖形化界面(mian)進行簡(jian)單的配(pei)置(zhi)就可以連(lian)接(jie)(jie)兩(liang)?云服務(wu)平臺，為業務(wu)輕松賦能。

原?協議?持：直(zhi)接使? TDengine Cloud 的原?協議傳輸數據，避(bi)免(mian)了 HTTP 連接的額外開(kai)銷(xiao)，提升了性能與穩定性。

?性能(neng)數(shu)(shu)據(ju)傳輸：優化的數(shu)(shu)據(ju)傳輸機制，確保物(wu)聯(lian)?數(shu)(shu)據(ju)能(neng)夠快速可(ke)靠地存儲(chu)到 TDengine Cloud。

靈活(huo)的數(shu)據處理：強(qiang)?的規則引擎?持，可根據業務需求對數(shu)據進(jin)?篩選、轉換和處理。

?站式配(pei)置(zhi)：?需分別管(guan)理 EMQX 和 TDengine 的連接參數，統?在 EMQX Cloud 控制(zhi)臺完成(cheng)所有配(pei)置(zhi)。

可視化監控(kong)：集成的(de)數據流(liu)監控(kong)功能，輕松了解(jie)數據流(liu)轉狀態(tai)與性能指標。

接下來，我們向(xiang)大家介紹如何使用該連(lian)接器實現 MQTT 數據(ju)接入 TDengine Cloud ：

EMQX Cloud 配置操作步驟

以下(xia)是配置 EMQX Cloud 與 TDengine Cloud 原(yuan)?連接的詳細步驟指南：

前置準備

1. EMQX Cloud 專有版部署：需要在 EMQX Cloud 平臺（）注冊并創建 EMQX Cloud 專有版部署 。（可免費體驗）
2. TDengine Cloud 賬戶：需要在 TDengine Cloud 平臺 () 注冊并創建數據庫實例。（可免費體驗）
3. ?絡配置：需要為 EMQX Cloud 專有版部署開通 NAT ?關，允許 EMQX Cloud 部署通過公?訪問 TDengine Cloud 實例。

步驟 1：TDengine Cloud 準備?作

1. 登錄 TDengine Cloud 控(kong)制臺 (//cloud.yakult-sh.com.cn/)

2. 創建(jian)并部署(shu) TDengine Cloud 服務實例(li)

3. 進(jin)?實例后(hou)，在左側菜單欄中點(dian)擊”數(shu)據瀏覽器”

4. 創(chuang)建數據庫，例如 “iot_data”

5. 在數(shu)據庫中創(chuang)建表：

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

6. 在(zai) TDengine Cloud 控制臺獲取連接 URL 和(he)訪問令牌(pai)：TDENGINE_CLOUD_URL、TDENGINE_CLOUD_TOKEN的值以備后?。

步驟 2：在 EMQX Cloud 創建TDengine連接器

1. 登錄(lu) EMQX Cloud 控制臺

2. 在(zai)部署菜單(dan)中選(xuan)擇(ze)”數據(ju)集成”，在(zai)數據(ju)持久化分類下選(xuan)擇(ze) TDengine

3. 點(dian)擊”新建連接器”，填寫以下(xia)信息(xi)：

• 連接器名稱：為連接器指定?個名稱，如 “TDengine Cloud”
• 主機列表：填寫 TDengine Cloud 提供的連接 （TDENGINE_CLOUD_URL的值）
• Token：填?從 TDengine Cloud 獲取的訪問令牌 （TDENGINE_CLOUD_TOKEN的值）
• 根據需要配置?級設置（可選）

4. 點擊”測試(shi)連(lian)接”按(an)鈕驗證連(lian)接狀態(tai)，成功后會(hui)顯(xian)示”連(lian)接器(qi)可?”提示 。

5. 點擊”新建(jian)”按(an)鈕完成連接器的創建(jian)

步驟 3：創建數據集成規則

1. 點(dian)擊剛(gang)創建(jian)的(de)連接(jie)器列表中”操作”列下的(de)”新(xin)建(jian)規則(ze)”圖標，或(huo)在”規則(ze)列表”中點(dian)擊”新(xin)建(jian)規則(ze)”

2. 在 SQL 編輯器(qi)中(zhong)輸?規則，定義需要處理(li)的消息，例如：

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

3. 點(dian)擊(ji)”SQL示例”和”啟?調試”按鈕可以學習和測試規則(ze) SQL 的結果（可選）

4. 點擊”下?步”開始創建動(dong)作 ：

步驟 4：配置動作

1. 從”使?連接器(qi)”下拉框中選擇您剛才創(chuang)建的 TDengine 連接器(qi)

2. 數據庫名(ming)字：填寫在 TDengine Cloud 中創建的數據庫名(ming)稱(cheng)，如 “iot_data”

3. 配(pei)置SQL模板，?于(yu)將數據寫?TDengine Cloud：

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

4. 啟?”未(wei)定義變量(liang)作為 NULL”選項，確(que)保規則(ze)引擎(qing)在變量(liang)未(wei)定義時(shi)能(neng)正確(que)處理(li) 。

5. 根(gen)據(ju)業務需求配置?級選項，如同(tong)步/異步模式、批量(liang)參(can)數等。（可(ke)選）

注：對消息延遲(chi)不敏感(gan)（延遲(chi)?于1s）的情況，可以將最?批量請求??從 1 修(xiu)改為 100，從?提(ti)?寫?性能。

6. 點擊”確認”按鈕完成動作配置(zhi)

7. 在彈出的”成(cheng)(cheng)功創建規則(ze)”提示框中(zhong)點擊”返回規則(ze)列(lie)表”，完成(cheng)(cheng)整個數據集成(cheng)(cheng)配(pei)置。

步驟 5：模擬數據上報

1. 在(zai) EMQX Cloud 部署菜單中選(xuan)擇”在(zai)線調(diao)試(shi)“，并點擊連接 。

2. 訂閱主題 devices/temp_hum 。

3. 向主題 devices/temp_hum 發送溫濕度數據 ：{"temp": 23, "hum": 90}

步驟 6：在 TDengine Cloud 查詢上報的數據

1. 訪問(wen) TDengine Cloud 數據瀏覽器 。

2. 查(cha)詢上報數據結果 。

SELECT * from iot_data7.temp_hum;

可以看到，數據(ju)已(yi)經經由 EMQX Cloud 寫(xie)入了(le) TDengine Cloud 當中。

關(guan)于TDengine Cloud 連接器更(geng)具體的使用，可以參考：

TDengine Cloud 配置操作步驟

關于 TDengine Cloud 一側，同樣可以通過部署 MQTT 數據源實現對 EMQX Cloud 的數據接入，具體操作參考TDengine 官方文檔：，以及該博客：//yakult-sh.com.cn/tdengine-engineering/27256.html。

寫在最后

目前， EMQX Cloud 只支持通過公網將數據接入 TDengine Cloud 當中(zhong)，后續還會更新以支持私有連接（private link）方(fang)式，進(jin)一步提升 EMQX Cloud 和 TDengine Cloud 用戶的(de)使用體(ti)驗。

面(mian)對數據洪流的挑戰與(yu)機遇，EMQX 與(yu) TDengine 的深(shen)度合作為行業(ye)帶來了突破性的技術解決方(fang)案。不僅構(gou)建(jian)了支撐海量數據處理的超高性能技術底座，更通過創新性的架構(gou)設計，重塑工業(ye)互聯(lian)網(wang)與(yu)物聯(lian)網(wang)的數據基礎設施標準(zhun)范(fan)式(shi)，助力企業(ye)在數智化轉型(xing)浪潮中獲得關(guan)鍵競爭優勢(shi)，開啟智能化發展的新篇章。