數(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ì)。 |
