數(shù)據(jù)匯聚方法、裝置、電子設(shè)備及存儲介質(zhì)

基本信息

申請?zhí)?/td> CN202110548797.9 申請日 -
公開(公告)號 CN113420048A 公開(公告)日 2021-09-21
申請公布號 CN113420048A 申請公布日 2021-09-21
分類號 G06F16/2455(2019.01)I 分類 計算;推算;計數(shù);
發(fā)明人 劉洋;王淼;孫小飛;李娜;劉芳亮 申請(專利權(quán))人 中交公規(guī)土木大數(shù)據(jù)信息技術(shù)(北京)有限公司
代理機構(gòu) 中科專利商標代理有限責(zé)任公司 代理人 周天宇
地址 100010北京市東城區(qū)前炒面胡同33號14號樓205室
法律狀態(tài) -

摘要

摘要 本公開提供一種數(shù)據(jù)匯聚方法,包括:采集道路感知數(shù)據(jù),通過持久化的消息隊列存儲方式,將所述道路感知數(shù)據(jù)進行緩存;讀取所述道路感知數(shù)據(jù),將所述道路感知數(shù)據(jù)封裝為MQTT數(shù)據(jù)包;基于Kafka流處理平臺,將所述MQTT數(shù)據(jù)包轉(zhuǎn)化為Kafka消息隊列;將所述Kafka消息隊列中的Kafka消息轉(zhuǎn)化為實體對象后進行數(shù)據(jù)處理,存儲處理后的數(shù)據(jù)至?xí)r序數(shù)據(jù)庫。本公開還提供一種數(shù)據(jù)匯聚裝置、電子設(shè)備及可讀存儲介質(zhì)。