現(xiàn)代新能源汽車，作為一種內(nèi)部系統(tǒng)極為復(fù)雜的交通工具，配備了大量傳感器、導(dǎo)航設(shè)備、應(yīng)用軟件，這些傳感器產(chǎn)生的數(shù)據(jù)都需要上報(bào)到車聯(lián)網(wǎng)平臺(tái)當(dāng)中。對(duì)于這些車輛的狀態(tài)數(shù)據(jù)（如車速、發(fā)動(dòng)機(jī)轉(zhuǎn)速等）、位置數(shù)據(jù)（經(jīng)緯度等）以及用戶行為數(shù)據(jù)，車聯(lián)網(wǎng)平臺(tái)需要對(duì)它們進(jìn)行實(shí)時(shí)/離線計(jì)算分析，從而為用戶提升駕駛體驗(yàn)，提供安全保障，為廠商提供質(zhì)量檢測(cè)、功能優(yōu)化，為交通管理部門提供流量、違章監(jiān)測(cè)、甚至為城市規(guī)劃提供幫助。

在車聯(lián)網(wǎng)領(lǐng)域中 MQTT 是十分常見的協(xié)議，它所具備的：能夠適應(yīng)不穩(wěn)定的網(wǎng)絡(luò)環(huán)境、輕量級(jí)、低延遲等特點(diǎn)，使其非常適合車輛數(shù)據(jù)的上報(bào)，也是目前主流的車聯(lián)網(wǎng)邊端-云端數(shù)據(jù)交互的通訊協(xié)議。

而 TDengine 是一款從誕生之初便致力于為工業(yè)、物聯(lián)網(wǎng)領(lǐng)域推動(dòng)信息化改革的時(shí)序大數(shù)據(jù)平臺(tái)。而車聯(lián)網(wǎng)作為物聯(lián)網(wǎng)的重要分支，自然也是 TDengine 主攻的領(lǐng)域之一。因此，在 TDengine Enterprise/TDengine Cloud 的外部數(shù)據(jù)源接入組件中，我們提供了諸如：MQTT、OPC-UA、OPC-DA 等數(shù)據(jù)直采的功能。讓用戶可以憑借十分簡(jiǎn)單的 Web 界面配置，無需任何一行代碼，便完成車聯(lián)網(wǎng)的位置、車輛狀態(tài)、用戶行為等數(shù)據(jù)的接入。

我們可以想象出這樣一個(gè)場(chǎng)景：

通過 TDengine 的 web 界面工具，訂閱 MQTT 的 “GPS” topic 們獲取全部車輛的 GPS 數(shù)據(jù)，然后把“GPS” topic 和 TDengine 中創(chuàng)建出來的“超級(jí)表 GPS”對(duì)應(yīng)起來，再把 MQTT 數(shù)據(jù)中的“車牌號(hào)”, “車型”，“汽車品牌”同 TDengine “GPS” 超級(jí)表中不同的標(biāo)簽映射起來。最終， MQTT 數(shù)據(jù)就可以源源不斷地接入TDengine 當(dāng)中了。

TDengine 的數(shù)據(jù)采集插件就像是一個(gè)翻譯官，它能理解 MQTT 數(shù)據(jù)結(jié)構(gòu)映射到時(shí)序庫(kù)數(shù)據(jù)結(jié)構(gòu)的需求，最終把他們巧妙地結(jié)合在一起。

那么，使用 TDengine 采集車聯(lián)網(wǎng)上報(bào)的 MQTT 數(shù)據(jù)到底有多簡(jiǎn)單？

抽象一下，只需要如下步驟：

1. 對(duì)于非 TDengine Enterprise（企業(yè)版）用戶，花 3 分鐘時(shí)間注冊(cè) TDengine Cloud ，https://cloud.taosdata.com/auth/login，根據(jù)提示兌換 600 元額度的免費(fèi)使用。

2. 在TDengine 中提前創(chuàng)建好一個(gè)數(shù)據(jù)庫(kù)，用于存放MQTT數(shù)據(jù)。（具體建庫(kù)參數(shù)值如需自定義，可參閱：https://docs.taosdata.com/reference/taos-sql/database/）

3. 確保代理插件和 MQTT server 處在同一網(wǎng)絡(luò)，然后根據(jù)提示，逐步復(fù)制粘貼，安裝代理插件并啟動(dòng)。

4. 新增數(shù)據(jù)源。

5. 按順序填寫/選擇：自定義的任務(wù)名稱；MQTT 類型；選擇剛剛創(chuàng)建的代理插件；填寫MQTT server 的 IP 和端口。 PS：這里可以用一個(gè)免費(fèi)的 MQTT server 做驗(yàn)證（broker.emqx.io:1883）。

6. 填寫 MQTT 協(xié)議版本、自定義的Client ID、和需要訂閱的主題（topic）以及該訂閱的 QOS （Quality of Service 服務(wù)質(zhì)量）級(jí)別，QOS 可選范圍為0、1、2，具體寫法參考示例即可。（用戶名密碼為選填項(xiàng)。）

7. 解析數(shù)據(jù)，在MQTT Payload 模塊中配置解析 MQTT 消息：

可以點(diǎn)擊從服務(wù)器檢索，從 MQTT Broker 獲得示例數(shù)據(jù)。也可以自己填寫 MQTT 消息體中的示例數(shù)據(jù)，例如：{“id”: 1, “message”: “hello-word”}{“id”: 2, “message”: “hello-word”}。

8. 獲得數(shù)據(jù)之后，可以選擇自定義的方式依次去處理這個(gè)json：

• 提取出列。
• 對(duì)提取出的列數(shù)據(jù)，通過分隔符、正則表達(dá)式等進(jìn)行提取或拆分：比如把“中國(guó)-北京”拆分成“中國(guó)”和“北京” 兩列。
• 對(duì)最終的結(jié)果進(jìn)行過濾：比如只取車速大于 xxx 的數(shù)據(jù)。。

9. 創(chuàng)建一個(gè)超級(jí)表，用于存儲(chǔ)MQTT數(shù)據(jù)。然后把剛剛處理過的 MQTT 數(shù)據(jù)結(jié)構(gòu)和 TDengine 的超級(jí)表做一個(gè)映射關(guān)系：這里我們可以使用各種靈活的方式處理映射關(guān)系。比如設(shè)置時(shí)間戳自動(dòng)生成、固定制、默認(rèn)值、以及最基本的匹配。

10. 填寫完成以上信息后，下拉到底部點(diǎn)擊“保存并應(yīng)用”按鈕，即可直接啟動(dòng)從 MQTT 到 TDengine 的數(shù)據(jù)同步了。

11.在這里看到連接代理和數(shù)據(jù)源任務(wù)都處于正常狀態(tài)之后，就可以去TDengine 中使用 SQL 語句檢查我們的 MQTT 數(shù)據(jù)了。

現(xiàn)在，我們已經(jīng)看到MQTT server 的數(shù)據(jù)正在源源不斷地寫入 TDengine 了。

在這個(gè)配置過程中，我們還能在 WEB 頁(yè)面看到很多其他配置項(xiàng)，但是他們都是選填項(xiàng)，這部分用戶可以根據(jù)實(shí)際情況填寫，比如：

1. 用戶名/密碼，SSL 認(rèn)證。
2. Keep Alive 和 Clean Session 為具體使用時(shí)候關(guān)于空連接釋放和是否記錄訂閱進(jìn)度的配置。
3. 代理插件的日志級(jí)別、日志保留天數(shù)、mqtt原始數(shù)據(jù)的保留設(shè)置。

現(xiàn)在，我們就已經(jīng)輕松完成了車輛 MQTT 數(shù)據(jù)的上傳。整個(gè)過程中，唯一耗時(shí)的地方，可能就在于 MQTT 數(shù)據(jù)結(jié)構(gòu)和 TDengine 的超級(jí)表結(jié)構(gòu)的匹配環(huán)節(jié)。如果您對(duì) TDengine 的“超級(jí)表-子表”的數(shù)據(jù)模型十分熟悉的話，想必不會(huì)花很多時(shí)間。