現(xian)代(dai)新能源汽(qi)車(che)(che)(che)，作為(wei)(wei)(wei)(wei)一種內(nei)部系統極(ji)為(wei)(wei)(wei)(wei)復雜的交通工(gong)具，配(pei)備(bei)(bei)了大量傳感器(qi)、導航(hang)設備(bei)(bei)、應用(yong)(yong)軟(ruan)件，這(zhe)些(xie)傳感器(qi)產生的數據都需要上報到(dao)車(che)(che)(che)聯網平(ping)臺當中(zhong)。對于這(zhe)些(xie)車(che)(che)(che)輛(liang)的狀態數據（如車(che)(che)(che)速、發動機轉速等(deng)）、位置數據（經緯度等(deng)）以及用(yong)(yong)戶(hu)行為(wei)(wei)(wei)(wei)數據，車(che)(che)(che)聯網平(ping)臺需要對它們進行實時/離線計算分析，從而為(wei)(wei)(wei)(wei)用(yong)(yong)戶(hu)提(ti)升駕駛體驗，提(ti)供安全保障，為(wei)(wei)(wei)(wei)廠(chang)商提(ti)供質量檢測(ce)、功能優化，為(wei)(wei)(wei)(wei)交通管理(li)部門提(ti)供流量、違章監測(ce)、甚(shen)至(zhi)為(wei)(wei)(wei)(wei)城市規(gui)劃提(ti)供幫助。

在車聯網領(ling)域(yu)中 MQTT 是十分(fen)常(chang)見(jian)的(de)(de)協議，它所(suo)具備的(de)(de)：能夠適應不穩定的(de)(de)網絡環(huan)境(jing)、輕(qing)量級、低(di)延(yan)遲等特點，使其非常(chang)適合(he)車輛(liang)數據的(de)(de)上報，也(ye)是目(mu)前主流的(de)(de)車聯網邊端(duan)-云端(duan)數據交互的(de)(de)通(tong)訊協議。

而 TDengine 是(shi)一(yi)款從誕生之(zhi)(zhi)初(chu)便致力(li)于為(wei)工業、物聯(lian)網(wang)(wang)領域(yu)推(tui)動信息化(hua)改(gai)革(ge)的(de)(de)時序大數據(ju)平臺。而車(che)聯(lian)網(wang)(wang)作(zuo)為(wei)物聯(lian)網(wang)(wang)的(de)(de)重要(yao)分支，自然也是(shi) TDengine 主攻的(de)(de)領域(yu)之(zhi)(zhi)一(yi)。因此，在 TDengine Enterprise/TDengine Cloud 的(de)(de)外部數據(ju)源接(jie)入組件中(zhong)，我們(men)提(ti)供了諸如：MQTT、OPC-UA、OPC-DA 等數據(ju)直采的(de)(de)功能。讓(rang)用戶(hu)可以(yi)憑(ping)借十分簡單的(de)(de) Web 界(jie)面配置，無需(xu)任(ren)何一(yi)行(xing)(xing)代(dai)碼，便完成車(che)聯(lian)網(wang)(wang)的(de)(de)位置、車(che)輛狀(zhuang)態、用戶(hu)行(xing)(xing)為(wei)等數據(ju)的(de)(de)接(jie)入。

我(wo)們可以想象出這(zhe)樣一(yi)個場景：

通(tong)過 TDengine 的(de)(de) web 界(jie)面工(gong)具，訂閱 MQTT 的(de)(de) “GPS” topic 們獲取全部(bu)車輛(liang)的(de)(de) GPS 數據，然后(hou)把“GPS” topic 和(he) TDengine 中創(chuang)建出來的(de)(de)“超級(ji)表 GPS”對應起來，再把 MQTT 數據中的(de)(de)“車牌號”, “車型”，“汽車品牌”同 TDengine “GPS” 超級(ji)表中不同的(de)(de)標簽映射(she)起來。最終， MQTT 數據就可以(yi)源(yuan)源(yuan)不斷地接入TDengine 當中了。

TDengine 的數(shu)據采集插件就像(xiang)是(shi)一個翻譯官，它能理解 MQTT 數(shu)據結(jie)構映射(she)到時序庫數(shu)據結(jie)構的需求，最(zui)終把他(ta)們巧(qiao)妙地結(jie)合在一起。

那么，使用 TDengine 采集車聯網上報的 MQTT 數據到底有多簡單？

抽象一下，只(zhi)需(xu)要(yao)如下步驟：

1. 對于(yu)非(fei) TDengine Enterprise（企(qi)業版）用戶，花(hua) 3 分(fen)鐘時間注冊 TDengine Cloud ，，根(gen)據提(ti)示兌換(huan) 600 元額(e)度的(de)免費使用。

2. 在TDengine 中提前創(chuang)建好(hao)一(yi)個數據(ju)庫(ku)，用于存放MQTT數據(ju)。（具體(ti)建庫(ku)參數值如需自定義，可參閱：）

3. 確保代理插件和 MQTT server 處在同一網絡，然后根據提示，逐步復制粘貼，安裝代理插件并啟動。

4. 新增數據源。

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

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

7. 解(jie)析數據，在MQTT Payload 模塊中(zhong)配置解(jie)析 MQTT 消(xiao)息：

可以(yi)點(dian)擊從服務器檢索，從 MQTT Broker 獲得示例數(shu)據。也可以(yi)自己(ji)填寫 MQTT 消息(xi)體中的示例數(shu)據，例如：{“id”: 1, “message”: “hello-word”}{“id”: 2, “message”: “hello-word”}。

8. 獲得數據(ju)之后，可以(yi)選擇自定義的方式依(yi)次去處理這個(ge)json：

• 提取出列。
• 對提取出的列數據，通過分隔符、正則表達式等進行提取或拆分：比如把“中國-北京”拆分成“中國”和“北京” 兩列。
• 對最終的結果進行過濾：比如只取車速大于 xxx 的數據。。

9. 創建一(yi)個超級表，用于存儲MQTT數據。然后把剛剛處理(li)過的(de) MQTT 數據結構和 TDengine 的(de)超級表做(zuo)一(yi)個映射關系：這里我們可以使用各種靈活的(de)方(fang)式處理(li)映射關系。比如(ru)設置時(shi)間(jian)戳自(zi)動生成、固(gu)定制、默認值、以及最(zui)基本(ben)的(de)匹配。

10. 填寫完成以上信息后，下拉到底(di)部點擊(ji)“保(bao)存并應用(yong)”按鈕，即可直接啟動(dong)從 MQTT 到 TDengine 的數(shu)據同步了。

11.在這(zhe)里(li)看到連接代(dai)理和(he)數(shu)(shu)據(ju)源任務都處于(yu)正常狀態之后，就可以去(qu)TDengine 中(zhong)使(shi)用 SQL 語句檢(jian)查我(wo)們的 MQTT 數(shu)(shu)據(ju)了。

現在(zai)，我們已(yi)經看到MQTT server 的數據正(zheng)在(zai)源源不斷地寫入 TDengine 了。

在這個(ge)配置(zhi)過(guo)程中，我們還能在 WEB 頁面看到(dao)很多其(qi)他配置(zhi)項，但是(shi)他們都是(shi)選填項，這部分(fen)用戶(hu)可(ke)以根據實際情況填寫，比如：

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

現(xian)在(zai)，我們就(jiu)(jiu)已經輕松完成(cheng)了車輛(liang) MQTT 數(shu)據(ju)的(de)上傳。整個過程中，唯一(yi)耗時的(de)地方，可能就(jiu)(jiu)在(zai)于(yu) MQTT 數(shu)據(ju)結構和 TDengine 的(de)超(chao)(chao)級表結構的(de)匹(pi)配環(huan)節。如(ru)果您(nin)對 TDengine 的(de)“超(chao)(chao)級表-子(zi)表”的(de)數(shu)據(ju)模型十分(fen)熟悉的(de)話(hua)，想必不會花很多時間。