王祝先
(黑龍江省氣象數(shù)據(jù)中心,黑龍江 哈爾濱150030)
數(shù)據(jù)收集與分發(fā)系統(tǒng)(CTS)是全國(guó)綜合氣象信息共享平臺(tái)(CIMISS)的一個(gè)重要組成系統(tǒng),負(fù)責(zé)數(shù)據(jù)收集、分發(fā)和處理,并為平臺(tái)中其他系統(tǒng)提供數(shù)據(jù)和服務(wù),同時(shí)也是CIMISS與外圍系統(tǒng)進(jìn)行數(shù)據(jù)交換的途徑之一。CTS支持媒體千萬(wàn)級(jí)文件數(shù)和TB文件量級(jí)的收集與分發(fā)業(yè)務(wù),提高了數(shù)據(jù)收集和分發(fā)效率。支持業(yè)務(wù)流程調(diào)度及監(jiān)視、TDCF表驅(qū)碼能力建設(shè)、各種資料的傳輸和格式檢查、二次開(kāi)發(fā)和擴(kuò)展維護(hù)等功能,是黑龍江省氣象行業(yè)統(tǒng)一數(shù)據(jù)收集、數(shù)據(jù)處理和收發(fā)監(jiān)視平臺(tái)。
在氣象資料的實(shí)時(shí)收集、收集分發(fā)處理、數(shù)據(jù)分發(fā)及其他業(yè)務(wù)處理過(guò)程中,氣象資料貫穿了整個(gè)數(shù)據(jù)收集與分發(fā)系統(tǒng),它是數(shù)據(jù)收集與分發(fā)系統(tǒng)建設(shè)的核心依據(jù)。由于氣象資料類(lèi)型的不同,就決定了其所經(jīng)過(guò)的處理流程存在差異,其數(shù)據(jù)源和分發(fā)目的地也就存在差異。因此,對(duì)于數(shù)據(jù)收集與分發(fā)系統(tǒng)來(lái)說(shuō),其業(yè)務(wù)需求主要體現(xiàn)在氣象數(shù)據(jù)規(guī)格,以及由其所驅(qū)動(dòng)的業(yè)務(wù)規(guī)程與流程。數(shù)據(jù)收集與分發(fā)系統(tǒng)的數(shù)據(jù)流程圖如圖1所示。
圖1 數(shù)據(jù)收集與分發(fā)系統(tǒng)數(shù)據(jù)流程圖
原始數(shù)據(jù)經(jīng)過(guò)數(shù)據(jù)收集與分發(fā)系統(tǒng)的數(shù)據(jù)收集、收集處理,依據(jù)一定的策略進(jìn)行數(shù)據(jù)存檔,并經(jīng)過(guò)分發(fā)處理,分發(fā)給不同用戶(hù),包括共享平臺(tái)內(nèi)的加工處理系統(tǒng)、省氣象行業(yè)部門(mén)等,同時(shí)將存檔的數(shù)據(jù)推送至數(shù)據(jù)存儲(chǔ)系統(tǒng)。這樣的數(shù)據(jù)流程既是數(shù)據(jù)流程的主要方式,也是數(shù)據(jù)收集與分發(fā)業(yè)務(wù)主線流程的體現(xiàn)。
數(shù)據(jù)收集與分發(fā)系統(tǒng)所涉及的氣象資料共有11大類(lèi),包括雷達(dá)氣象資料、地面氣象資料、高空氣象資料、衛(wèi)星氣象資料、數(shù)值分析預(yù)報(bào)產(chǎn)品、大氣成分資料、農(nóng)業(yè)氣象與生態(tài)氣象資料、海洋氣象資料、氣象輻射資料、氣象服務(wù)產(chǎn)品和其他資料。上述每一類(lèi)氣象觀測(cè)資料和產(chǎn)品在文件大小、文件數(shù)、數(shù)據(jù)量都有其不同的特性。比如數(shù)值分析預(yù)報(bào)產(chǎn)品中的T639全球中期天氣數(shù)值預(yù)報(bào)系統(tǒng)產(chǎn)品和氣象衛(wèi)星資料中的一些產(chǎn)品每個(gè)文件比較大,每日的數(shù)據(jù)量也比較大,而雷達(dá)氣象資料的特點(diǎn)是每個(gè)文件不大,但文件數(shù)量極其多,每日需傳輸?shù)臄?shù)據(jù)總量大,傳輸?shù)臅r(shí)次也高(間隔6 min)。各類(lèi)數(shù)據(jù)不同的特性對(duì)整個(gè)系統(tǒng)的穩(wěn)定可靠性和高時(shí)效性的運(yùn)行提出了不同的要求。本文通過(guò)對(duì)幾種不同數(shù)據(jù)的數(shù)據(jù)流程的描述,說(shuō)明本系統(tǒng)建設(shè)內(nèi)容的四大關(guān)鍵需求是可以滿足氣象數(shù)據(jù)的業(yè)務(wù)需求的,同時(shí),不同數(shù)據(jù)對(duì)系統(tǒng)的可靠性和時(shí)效性的不同要求,也對(duì)系統(tǒng)的非功能性提出了需求。下面首先以多普勒雷達(dá)基數(shù)據(jù)為例,對(duì)數(shù)據(jù)流程加以概要的描述。
省級(jí)數(shù)據(jù)收集與分發(fā)系統(tǒng)的收集分系統(tǒng)接收到多普勒雷達(dá)站傳送到的雷達(dá)壓縮基數(shù)據(jù)后,經(jīng)過(guò)收集處理分系統(tǒng)的解壓縮、文件格式轉(zhuǎn)換等處理后,形成統(tǒng)一格式的雷達(dá)基數(shù)據(jù),分發(fā)處理分系統(tǒng)對(duì)雷達(dá)基數(shù)據(jù)進(jìn)行分發(fā)前的數(shù)據(jù)組織,然后通過(guò)數(shù)據(jù)分發(fā)分系統(tǒng)將解壓縮的基數(shù)據(jù)送到臨時(shí)文件庫(kù),同時(shí)將需要?dú)w檔的原始雷達(dá)基數(shù)據(jù)送到歸檔目錄,將壓縮基數(shù)據(jù)上傳給國(guó)家級(jí)收發(fā)系統(tǒng)或分發(fā)給指定用戶(hù)。國(guó)家級(jí)收發(fā)系統(tǒng)收到數(shù)據(jù)后,實(shí)現(xiàn)上述收發(fā)系統(tǒng)類(lèi)似的功能。雷達(dá)基數(shù)據(jù)經(jīng)數(shù)據(jù)收集與分發(fā)系統(tǒng)的數(shù)據(jù)流程如圖2所示。
圖2 雷達(dá)基數(shù)據(jù)傳輸流程圖
雷達(dá)基數(shù)據(jù)的時(shí)效性需求極高,一般要求每個(gè)體掃完成后開(kāi)始傳送,每次體掃生成的產(chǎn)品最晚應(yīng)在下次體掃前傳送至國(guó)家中心,因此,高時(shí)效性是數(shù)據(jù)收集與分發(fā)系統(tǒng)滿足雷達(dá)數(shù)據(jù)的實(shí)時(shí)收集與實(shí)時(shí)分發(fā)最重要的特性需求之一。從雷達(dá)數(shù)據(jù)在數(shù)據(jù)收集與分發(fā)系統(tǒng)中的數(shù)據(jù)流程的分析考慮,會(huì)采用減少I(mǎi)/0讀寫(xiě)操作、多線程并行機(jī)制和優(yōu)先級(jí)隊(duì)列調(diào)度等技術(shù)來(lái)滿足海量雷達(dá)數(shù)據(jù)的實(shí)時(shí)收集與實(shí)時(shí)發(fā)送。
以全球中期數(shù)值預(yù)報(bào)系統(tǒng)產(chǎn)品(T639)為例,省級(jí)數(shù)據(jù)收集與分發(fā)系統(tǒng)收到CMACast廣播的T639數(shù)據(jù)產(chǎn)品后,經(jīng)過(guò)省級(jí)收發(fā)系統(tǒng)的收集處理、分發(fā)處理,按需要推送至省級(jí)氣象業(yè)務(wù)部門(mén)、省級(jí)同城行業(yè)用戶(hù)、省級(jí)共享平臺(tái)內(nèi)部臨時(shí)文件庫(kù)和歸檔目錄。全球中期數(shù)值預(yù)報(bào)系統(tǒng)產(chǎn)品的數(shù)據(jù)流程圖如圖3所示。
圖3 T639傳輸流程圖
對(duì)T639數(shù)值預(yù)報(bào)產(chǎn)品,尤其像前面提到的氣象衛(wèi)星資料,文件比較大,在文件傳輸過(guò)程中就必須考慮滿足這種大文件傳輸業(yè)務(wù)需求的技術(shù)方案,結(jié)合分片傳輸、重傳機(jī)制和斷點(diǎn)續(xù)傳,采用多線程技術(shù),就可以保證數(shù)據(jù)傳輸?shù)母呖煽啃浴?/p>
通過(guò)對(duì)上述不同種類(lèi)氣象數(shù)據(jù)資料和產(chǎn)品的收發(fā)需求以及數(shù)據(jù)流程分析,提取出這些數(shù)據(jù)最重要的屬性(如文件大小,文件數(shù),數(shù)據(jù)量,時(shí)次),基于這些重要屬性,對(duì)氣象數(shù)據(jù)資料和產(chǎn)品進(jìn)行區(qū)分,并把各類(lèi)氣象數(shù)據(jù)資料和產(chǎn)品從系統(tǒng)的可靠性、穩(wěn)定性和時(shí)效性再加以分類(lèi),這樣在實(shí)現(xiàn)數(shù)據(jù)收集與分發(fā)系統(tǒng)功能性需求的同時(shí),結(jié)合數(shù)據(jù)規(guī)格說(shuō)明書(shū)中數(shù)據(jù)分析的結(jié)果,對(duì)不同種類(lèi)的數(shù)據(jù)采取不同的技術(shù)方案,充分考慮系統(tǒng)的非功能性需求,以滿足對(duì)氣象數(shù)據(jù)資料和產(chǎn)品實(shí)時(shí)收集與實(shí)時(shí)分發(fā)的要求。