[發(fā)明專利]一種基于云存儲的數(shù)據(jù)管理系統(tǒng)及方法

有效

• 申請?zhí)枺?/td>: 201811140108.5
• 申請日: 2018-09-28
• 公開（公告）號: CN109271113B
• 公開（公告）日: 2022-03-29
• 發(fā)明（設計）人: 王敏;王聰
• 申請（專利權）人: 武漢烽火眾智數(shù)字技術有限責任公司
• 主分類號: G06F3/06
• 分類號: G06F3/06;H04L67/1097
• 代理公司: 北京匯澤知識產權代理有限公司 11228
• 代理人: 程殿軍

1.一種基于云存儲的數(shù)據(jù)管理系統(tǒng)，其特征在于，所述系統(tǒng)包括前端卡口、過車信息服務器和云存儲中心，其中，

所述前端卡口，用于采集過車信息，并將所采集的過車信息發(fā)送給過車信息服務器；

所述過車信息服務器，用于接收并解析所述過車信息，得到過車時間和過車圖像數(shù)據(jù)，從所有的預設Bucket標識中選擇所述過車時間所屬時間段所對應的目標Bucket標識；向所述云存儲中心發(fā)送查詢請求，若接收到Bucket可用消息，則選擇所述目標Bucket標識對應的目標打包寫對象，將目標打包寫對象作為當前打包寫對象，將所述過車圖像數(shù)據(jù)寫入所述當前打包寫對象所作用的文件，并基于寫入圖像數(shù)據(jù)后的文件生成存儲請求，將所述存儲請求發(fā)送給云存儲中心；其中，一個預設Bucket標識對應一個預設時間段；一個預設Bucket標識對應一個打包寫對象；

所述云存儲中心，用于按照所述查詢請求，判斷具有所述目標Bucket標識的目標Bucket是否存在且可用，若目標Bucket存在且可用，則向過車信息服務器返回Bucket可用消息；在接收到存儲請求后，緩存所述存儲請求中的文件，并判斷當前緩存總容量是否達到預設緩存值，若達到，則將緩存的所有文件寫入所述目標Bucket；

所述系統(tǒng)還包括大數(shù)據(jù)中心和客戶端，

所述過車信息服務器，還用于對所述過車信息進行結構化處理，得到結構化的車輛數(shù)據(jù)，將所述車輛數(shù)據(jù)發(fā)送給大數(shù)據(jù)中心；

所述大數(shù)據(jù)中心，用于對所接收的車輛數(shù)據(jù)進行存儲，在接收到客戶端發(fā)送的數(shù)據(jù)搜索請求后，按照所述數(shù)據(jù)搜索請求中的數(shù)據(jù)碰撞條件，對所存儲的車輛數(shù)據(jù)進行數(shù)據(jù)碰撞，得到滿足所述數(shù)據(jù)碰撞條件的數(shù)據(jù)碰撞結果，并將所述數(shù)據(jù)碰撞結果返回給客戶端；

所述客戶端，用于向大數(shù)據(jù)中心發(fā)送數(shù)據(jù)搜索請求；接收并顯示所述數(shù)據(jù)碰撞結果。

2.根據(jù)權利要求1所述的系統(tǒng)，其特征在于，

所述云存儲中心，還用于接收客戶端發(fā)送的圖像訪問請求，按照所述圖像訪問請求中的訪問條件，查找滿足所述訪問條件的目標圖像數(shù)據(jù)，將所述目標圖像數(shù)據(jù)返回給客戶端；

所述客戶端，還用于向所述云存儲中心發(fā)送圖像訪問請求；接收并顯示所述目標圖像數(shù)據(jù)。

3.根據(jù)權利要求2所述的系統(tǒng)，其特征在于，

所述過車信息服務器，還用于獲得配置文件；將所述配置文件發(fā)送給所述云存儲中心；所述配置文件包括待配置Bucket的保留時間；

所述云存儲中心，還用于按照所接收的配置文件，設置所述待配置Bucket的生命周期為所述保留時間。

4.根據(jù)權利要求3所述的系統(tǒng)，其特征在于，

所述云存儲中心，還用于在成功將緩存的所有文件寫入目標Bucket后，將被寫入目標Bucket的各文件的文件名及存儲位置發(fā)送給所述過車信息服務器；

所述過車信息服務器，還用于將所述過車信息中圖像數(shù)據(jù)的存儲位置加入來自于該過車信息的車輛數(shù)據(jù)，其中，圖像數(shù)據(jù)的存儲位置為該圖像數(shù)據(jù)被寫入的文件的存儲位置。

5.根據(jù)權利要求1所述的系統(tǒng)，其特征在于，所述文件為小文件，過車信息服務器將所述過車圖像數(shù)據(jù)寫入所述當前打包寫對象所作用的文件，具體為：

采用原子操作方式，打開所述當前打包寫對象所作用的小文件，并將所述過車圖像數(shù)據(jù)寫入所打開的小文件；

在寫入完成后，關閉小文件并生成文件名。

6.根據(jù)權利要求1所述的系統(tǒng)，其特征在于，

所述過車信息服務器，還用于若接收到Bucket不可用消息，則向所述云存儲中心發(fā)送創(chuàng)建Bucket請求，所述創(chuàng)建Bucket請求包括初始Bucket標識；獲得所述初始Bucket標識對應的時間段以及所述初始Bucket標識對應的初始打包寫對象；其中，所述初始Bucket標識對應的時間段包括所述過車時間；將初始打包寫對象作為當前打包寫對象，返回執(zhí)行將所述過車圖像數(shù)據(jù)寫入所述當前打包寫對象所作用的文件；

所述云存儲中心，還用于若目標Bucket不存在或不可用，則向過車信息服務器返回Bucket不可用消息；在接收到創(chuàng)建Bucket請求后，創(chuàng)建具有所述初始Bucket標識的初始Bucket。