小T導(dǎo)讀：在智慧港口的建設(shè)過程中，面對(duì)海量物聯(lián)網(wǎng)設(shè)備產(chǎn)生的時(shí)序數(shù)據(jù)（如設(shè)備狀態(tài)、能耗、作業(yè)效率等）的高效接入與實(shí)時(shí)分析需求，山東港口科技選擇采用 TDengine TSDB 時(shí)序數(shù)據(jù)庫作為核心數(shù)據(jù)底座，以應(yīng)對(duì)傳統(tǒng)關(guān)系型數(shù)據(jù)庫在處理高并發(fā)、大規(guī)模時(shí)序數(shù)據(jù)時(shí)的性能瓶頸，實(shí)現(xiàn)設(shè)備狀態(tài)的實(shí)時(shí)監(jiān)控、數(shù)據(jù)壓縮存儲(chǔ)與智能分析，為智慧港口的數(shù)字化轉(zhuǎn)型與智能化運(yùn)營(yíng)提供強(qiáng)有力的數(shù)據(jù)支撐。本次將就此實(shí)踐進(jìn)行具體分享。

合作背景

在“智慧港口”的宏偉藍(lán)圖下，山東港口科技集團(tuán)面臨著海量物聯(lián)網(wǎng)設(shè)備數(shù)據(jù)接入、處理與分析的嚴(yán)峻挑戰(zhàn)。港口作業(yè)涉及大量的橋吊、門機(jī)、集卡、傳感器等終端設(shè)備，這些設(shè)備 7×24 小時(shí)不間斷產(chǎn)生巨量的時(shí)序數(shù)據(jù)（如位置、狀態(tài)、能耗、效率指標(biāo)等）。傳統(tǒng)的通用關(guān)系型數(shù)據(jù)庫在處理這類高并發(fā)、海量的時(shí)序數(shù)據(jù)時(shí)，顯得力不從心。為了夯實(shí)智慧港口的數(shù)據(jù)根基，經(jīng)過嚴(yán)謹(jǐn)?shù)?a href="http://www.fjzmyy.cn/time-series-database-selection-guide" data-internallinksmanager029f6b8e52c="17" title="時(shí)序數(shù)據(jù)庫選型指南">選型，我們最終選擇了 TDengine TSDB 作為核心時(shí)序數(shù)據(jù)平臺(tái)，以支撐關(guān)鍵業(yè)務(wù)系統(tǒng)的數(shù)字化轉(zhuǎn)型。

選擇 TDengine TSDB 的原因

在引入 TDengine TSDB 之前，我們的業(yè)務(wù)系統(tǒng)主要面臨以下痛點(diǎn)：

• 數(shù)據(jù)膨脹與存儲(chǔ)成本高： 港口設(shè)備每秒產(chǎn)生數(shù)以萬計(jì)的數(shù)據(jù)點(diǎn)，若采用傳統(tǒng)數(shù)據(jù)庫存儲(chǔ)，數(shù)據(jù)表會(huì)急劇膨脹，不僅占用大量存儲(chǔ)空間，且備份和維護(hù)成本高昂。
• 查詢分析效率瓶頸： 對(duì)于實(shí)時(shí)監(jiān)控、效率分析和歷史數(shù)據(jù)回溯等場(chǎng)景，傳統(tǒng)數(shù)據(jù)庫的查詢響應(yīng)速度慢，無法滿足業(yè)務(wù)對(duì)“實(shí)時(shí)洞察”的要求，特別是在聚合計(jì)算大量設(shè)備的歷史數(shù)據(jù)時(shí)，耗時(shí)長(zhǎng)達(dá)分鐘甚至小時(shí)級(jí)。
• 系統(tǒng)架構(gòu)復(fù)雜： 為了應(yīng)對(duì)不同的數(shù)據(jù)處理需求（如實(shí)時(shí)、短期、長(zhǎng)期），往往需要組合使用多種數(shù)據(jù)庫和技術(shù)棧（如 Redis、MySQL、Hadoop 等），這增加了系統(tǒng)架構(gòu)的復(fù)雜性、開發(fā)和運(yùn)維難度。

TDengine TSDB 作為專為時(shí)序數(shù)據(jù)設(shè)計(jì)的數(shù)據(jù)庫，其超高性能、內(nèi)置緩存和流式計(jì)算功能、極簡(jiǎn)的架構(gòu)以及強(qiáng)大的數(shù)據(jù)壓縮能力，恰好精準(zhǔn)地解決了上述痛點(diǎn)，成為我們的理想選擇。

使用 TDengine TSDB 后的收益與業(yè)務(wù)提升

部署 TDengine TSDB 后，我們?cè)诙鄠€(gè)方面獲得了顯著收益：

• 極致的性能提升： 對(duì)港口設(shè)備運(yùn)行狀態(tài)的查詢響應(yīng)速度從原來的“分鐘級(jí)”提升到“毫秒級(jí)”，實(shí)現(xiàn)了真正的實(shí)時(shí)監(jiān)控與告警。
• 顯著的降本增效：TDengine TSDB 高效的數(shù)據(jù)壓縮技術(shù)，使得存儲(chǔ)空間節(jié)省超過 80%，大幅降低了硬件與運(yùn)維成本，簡(jiǎn)化的架構(gòu)也減少了運(yùn)維團(tuán)隊(duì)的工作負(fù)擔(dān)。
• 增強(qiáng)的數(shù)據(jù)驅(qū)動(dòng)能力：借助 TDengine TSDB 強(qiáng)大的時(shí)序數(shù)據(jù)計(jì)算能力，業(yè)務(wù)團(tuán)隊(duì)能夠輕松進(jìn)行設(shè)備效率分析、預(yù)測(cè)性維護(hù)和運(yùn)營(yíng)優(yōu)化，為決策提供堅(jiān)實(shí)的數(shù)據(jù)支持，進(jìn)一步強(qiáng)化了“智慧港口解決方案”的核心優(yōu)勢(shì)。
• 加速創(chuàng)新應(yīng)用落地：借助 TDengine TSDB 這一穩(wěn)定的高性能數(shù)據(jù)底座，我們能夠快速開發(fā)和部署新的數(shù)據(jù)密集型應(yīng)用，如全自動(dòng)碼頭的智能調(diào)度系統(tǒng)、物流供應(yīng)鏈的可視化平臺(tái)等。

核心業(yè)務(wù)場(chǎng)景與 TDengine TSDB 應(yīng)用實(shí)例

場(chǎng)景一：港口岸橋設(shè)備實(shí)時(shí)狀態(tài)監(jiān)控與效率分析

• 業(yè)務(wù)描述： 實(shí)時(shí)監(jiān)控碼頭所有岸橋（Quay Crane）的運(yùn)行狀態(tài)（如起升、下降、大車行走、小車行走）、能耗以及作業(yè)效率（如單箱能耗、作業(yè)周期），確保設(shè)備安全高效運(yùn)行，并即時(shí)發(fā)現(xiàn)異常。
• TDengine TSDB 查詢 SQL 示例：

-- 1. 查詢指定岸橋（Crane_ID = 'QC08') 在過去10分鐘內(nèi)的平均功率和總能耗
SELECT AVG(power_kw), SUM(power_kw * ts_interval / 3600) AS total_energy_kwh
FROM crane_power_metrics
WHERE crane_id = 'QC08' AND ts >= NOW - 10m
INTERVAL(1m);

-- 2. 統(tǒng)計(jì)過去1小時(shí)內(nèi)，所有岸橋的作業(yè)箱量（基于每次吊裝動(dòng)作計(jì)數(shù)）
SELECT crane_id, COUNT(*) AS operation_count
FROM crane_operation_events
WHERE ts >= NOW - 1h AND operation_type = 'lift_complete'
GROUP BY crane_id;?

通過 TDengine TSDB 毫秒級(jí)查詢與高效聚合能力，我們實(shí)現(xiàn)了對(duì)數(shù)百臺(tái)岸橋設(shè)備運(yùn)行狀態(tài)的實(shí)時(shí)監(jiān)控（1 分鐘粒度）與異常秒級(jí)捕捉，查詢效率從分鐘級(jí)提升至毫秒級(jí)，存儲(chǔ)成本降低超 80%，極大提升了設(shè)備管理實(shí)時(shí)性與安全性。

場(chǎng)景二：智能集卡（AGV/IGV）調(diào)度與路徑優(yōu)化

• 業(yè)務(wù)描述： 追蹤自動(dòng)化碼頭內(nèi)數(shù)百臺(tái)智能導(dǎo)引車（AGV）的實(shí)時(shí)位置、速度、電池電量和狀態(tài)，基于這些時(shí)序數(shù)據(jù)進(jìn)行最優(yōu)路徑規(guī)劃和調(diào)度，避免擁堵，提升整體物流周轉(zhuǎn)效率。
• TDengine TSDB 查詢 SQL 示例：

-- 1. 查詢所有電量低于20%的AGV的當(dāng)前位置和最新電量
SELECT last(latitude), last(longitude), last(battery_level)
FROM agv_status_metrics
WHERE battery_level < 20
GROUP BY agv_id;

-- 2. 計(jì)算指定區(qū)域（如A01區(qū)）過去5分鐘內(nèi)的平均車輛速度，用于判斷擁堵情況
SELECT AVG(speed_kmh) AS avg_speed
FROM agv_location_metrics
WHERE ts >= NOW - 5m AND zone_id = 'A01';

借助 TDengine TSDB 的 last() 實(shí)時(shí)狀態(tài)查詢與窗口聚合能力，我們實(shí)現(xiàn)了對(duì)數(shù)百臺(tái) AGV 的實(shí)時(shí)位置、電量及速度監(jiān)控，低電量車輛識(shí)別與區(qū)域擁堵判斷均達(dá)到秒級(jí)響應(yīng)，調(diào)度效率提升約 50%~70%，整體物流周轉(zhuǎn)更高效、更智能。

場(chǎng)景三：港口風(fēng)速風(fēng)向監(jiān)測(cè)與預(yù)警

• 業(yè)務(wù)描述：分布在港區(qū)各處的氣象站持續(xù)采集風(fēng)速、風(fēng)向數(shù)據(jù)。系統(tǒng)需要實(shí)時(shí)判斷是否超過安全作業(yè)閾值，并及時(shí)向相關(guān)設(shè)備和人員發(fā)出預(yù)警，保障惡劣天氣下的作業(yè)安全。
• TDengine TSDB 流計(jì)算 SQL 示例：

-- 創(chuàng)建流式計(jì)算，持續(xù)監(jiān)控風(fēng)速，一旦發(fā)現(xiàn)某個(gè)站點(diǎn)每分鐘一次的平均風(fēng)速超過閾值（18m/s），則觸發(fā)告警
CREATE STREAM wind_alert_stream
INTO wind_alert_events
AS
SELECT _wstart AS ts, station_id, AVG(wind_speed) AS avg_wind_speed
FROM weather_station_metrics 
PARTITION BY station_id
INTERVAL(1m) SLIDING(1m);

-- 查詢歷史告警記錄
SELECT * FROM wind_alert_events WHERE ts >= TODAY ORDER BY ts DESC;

解析如下：

• CREATE STREAM wind_alert_stream 定義了一個(gè)名為 wind_alert_stream的流，用于持續(xù)處理實(shí)時(shí)數(shù)據(jù)。
• INTO wind_alert_events 將流計(jì)算的結(jié)果寫入到 TDengine TSDB 中的 wind_alert_events表中，該表為一個(gè)超級(jí)表，按照分組會(huì)自動(dòng)生成子表，用于存儲(chǔ)每個(gè)分組的告警事件。
• SELECT _wstart AS ts, station_id, AVG(wind_speed) AS avg_wind_speed 選擇數(shù)據(jù)流中的時(shí)間戳（_wstart）、站點(diǎn) ID（station_id）以及風(fēng)速的平均值（AVG(wind_speed)）。_wstart是該時(shí)間窗口的起始時(shí)間，作為告警觸發(fā)的時(shí)間點(diǎn)。
• FROM weather_station_metrics 數(shù)據(jù)源是 weather_station_metrics表，該表應(yīng)包含字段如：ts（時(shí)間戳）、station_id（站點(diǎn) ID）、wind_speed（風(fēng)速-單位：m/s）等。
• PARTITION BY station_id 按站點(diǎn)分組，每個(gè)站點(diǎn)獨(dú)立計(jì)算，避免不同站點(diǎn)之間的數(shù)據(jù)干擾。
• INTERVAL(1m) SLIDING(1m) 定義了 1 分鐘的時(shí)間窗口，每 1 分鐘滑動(dòng)一次，即每分鐘統(tǒng)計(jì)一次過去 1 分鐘內(nèi)的數(shù)據(jù)。

借助 TDengine TSDB 靈活的流計(jì)算能力（1 分鐘滑動(dòng)窗口），我們實(shí)現(xiàn)了港口風(fēng)速的實(shí)時(shí)監(jiān)測(cè)與自動(dòng)告警（響應(yīng)時(shí)間＜1 分鐘）。原本需要多個(gè)大數(shù)據(jù)組件才能完成的處理流程，如今只需一條語句即可完成，告警的準(zhǔn)確性與時(shí)效性顯著提升，安全運(yùn)維效率也隨之大幅提高。

結(jié)語

通過引入 TDengine TSDB，我們成功構(gòu)建了一個(gè)高性能、高可用的時(shí)序數(shù)據(jù)管理平臺(tái)，有效解決了智慧港口建設(shè)中海量物聯(lián)網(wǎng)數(shù)據(jù)處理的核心難題。這一合作不僅提升了現(xiàn)有業(yè)務(wù)的運(yùn)營(yíng)效率和智能化水平，也為未來探索更多基于數(shù)據(jù)的創(chuàng)新應(yīng)用（如數(shù)字孿生港口）奠定了堅(jiān)實(shí)的基礎(chǔ)，有力地支撐了山東港口科技集團(tuán)有限公司打造“行業(yè)領(lǐng)先的高新技術(shù)上市企業(yè)”的戰(zhàn)略目標(biāo)。

關(guān)于山東港口科技

山東港口科技集團(tuán)有限公司是山東省港口集團(tuán)為全力推進(jìn)智慧港口建設(shè)而設(shè)立的高科技子公司。公司立足信息化頂層設(shè)計(jì)、核心應(yīng)用系統(tǒng)研發(fā)和大數(shù)據(jù)應(yīng)用，致力于打造物流供應(yīng)鏈服務(wù)平臺(tái)、智慧港口解決方案和自動(dòng)化應(yīng)用系統(tǒng)三大核心優(yōu)勢(shì)。作為一家以創(chuàng)新為驅(qū)動(dòng)的高新技術(shù)企業(yè)，科技集團(tuán)正積極利用數(shù)字技術(shù)，為全球港口行業(yè)的智能化升級(jí)注入科技力量。

作者：張艷明