一種可保持janusGraph數(shù)據(jù)一致性的分布式高效并行加載方法

基本信息

申請?zhí)?/td> CN202011622773.5 申請日 -
公開（公告）號 CN112685419B 公開（公告）日 2021-09-10
申請公布號 CN112685419B 申請公布日 2021-09-10
分類號 G06F16/22;G06F16/23;G06F16/2458;G06F16/27;G06F9/54 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 謝銘;蒲路;孟憲文 申請（專利權(quán)）人 北京賽思信安技術(shù)股份有限公司
代理機(jī)構(gòu) 北京永創(chuàng)新實(shí)專利事務(wù)所 代理人 易卜
地址 100125 北京市朝陽區(qū)霞光里8號承冀誠大廈二層
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種可保持janusGraph實(shí)時(shí)數(shù)據(jù)一致性的高效并行加載方法，屬于分布式圖數(shù)據(jù)庫領(lǐng)域，首先構(gòu)建分布式結(jié)構(gòu)；創(chuàng)建兩個(gè)空的分布式隊(duì)列；然后，實(shí)時(shí)接收數(shù)據(jù)并解析后存入隊(duì)列一中；數(shù)據(jù)處理模塊逐條取出，調(diào)用分布式索引模塊中存在對應(yīng)ID的數(shù)據(jù)加載到圖數(shù)據(jù)庫中，并將無法調(diào)用ID的點(diǎn)的唯一標(biāo)志存入隊(duì)列二中，點(diǎn)處理模塊判斷能否獲取各標(biāo)志對應(yīng)的ID，如果能，則繼續(xù)獲取下一個(gè)進(jìn)行判斷；否則，將各標(biāo)志加載到圖數(shù)據(jù)庫中，并產(chǎn)生對應(yīng)的ID；同時(shí)將S與ID的對應(yīng)關(guān)系保存；集群管理模塊找尋主節(jié)點(diǎn)，并對各子節(jié)點(diǎn)分發(fā)任務(wù)，各子節(jié)點(diǎn)并行處理各自的分布式隊(duì)列分區(qū)中的數(shù)據(jù)。本發(fā)明保證數(shù)據(jù)一致性的同時(shí)提高實(shí)時(shí)數(shù)據(jù)的并行加載。