[發(fā)明專利]同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202011591917.5
• 申請日: 2020-12-29
• 公開（公告）號(hào): CN112632294B
• 公開（公告）日: 2022-09-09
• 發(fā)明（設(shè)計(jì)）人: 葛煜;徐志欣
• 申請（專利權(quán)）人: 蘇寧金融科技（南京）有限公司
• 主分類號(hào): G06F16/36
• 分類號(hào): G06F16/36;G06F16/901
• 代理公司: 北京市萬慧達(dá)律師事務(wù)所 11111
• 代理人: 黃玉東

本發(fā)明公開同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法及系統(tǒng)，其中，該方法包括：啟動(dòng)Neo4j圖數(shù)據(jù)庫，創(chuàng)建搜索服務(wù)器客戶端，構(gòu)造事務(wù)事件處理器，并將所述事務(wù)事件處理器注冊到Neo4j服務(wù)中去；利用所述事務(wù)事件處理器將圖數(shù)據(jù)節(jié)點(diǎn)和圖數(shù)據(jù)關(guān)系分別構(gòu)造成搜索服務(wù)器的文檔請求對象并存儲(chǔ)到Map中；利用所述事務(wù)事件處理器基于所述文檔請求對象構(gòu)造搜索服務(wù)器的批量文檔請求對象，利用搜索服務(wù)器客戶端將所述批量文檔請求對象同步到搜索服務(wù)器集群中。本發(fā)明提供的同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的系統(tǒng)，采用上述同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法，解決了如何將Neo4j中的圖數(shù)據(jù)實(shí)時(shí)同步到搜索服務(wù)器中的問題。

技術(shù)領(lǐng)域

本發(fā)明涉及圖數(shù)據(jù)庫技術(shù)領(lǐng)域，尤其涉及同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法及系統(tǒng)。

背景技術(shù)

Neo4j圖數(shù)據(jù)庫是一個(gè)非常流行的圖數(shù)據(jù)庫，提供了強(qiáng)大且穩(wěn)定的圖存儲(chǔ)和圖查詢功能，在知識(shí)圖譜應(yīng)用領(lǐng)域有廣泛應(yīng)用，而搜索服務(wù)器經(jīng)常被用來為應(yīng)用系統(tǒng)的搜索服務(wù)提供支持。

圖譜可視化是知識(shí)圖譜的一個(gè)應(yīng)用領(lǐng)域，通常包含了圖數(shù)據(jù)的搜索查詢和展現(xiàn)等服務(wù)。在知識(shí)圖譜的可視化應(yīng)用場景中，可以使用搜索服務(wù)器輔助構(gòu)建針對圖數(shù)據(jù)的查詢服務(wù)，將圖數(shù)據(jù)同步到搜索服務(wù)器集群中，進(jìn)而從搜索服務(wù)器中高效地查詢圖數(shù)據(jù)，以避免直接從Neo4j圖庫中全量掃描數(shù)據(jù)，從而提高針對圖數(shù)據(jù)的搜索服務(wù)性能。因此，將Neo4j中的圖數(shù)據(jù)實(shí)時(shí)同步到搜索服務(wù)器中，是一個(gè)必須要解決的問題。

發(fā)明內(nèi)容

本發(fā)明的目的在于提供同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法及系統(tǒng)，解決了如何將Neo4j中的圖數(shù)據(jù)實(shí)時(shí)同步到搜索服務(wù)器中的問題。

為了實(shí)現(xiàn)上述目的，本發(fā)明提供如下技術(shù)方案：

一種同步Neo4j中數(shù)據(jù)到搜索服務(wù)器的方法，包括：

啟動(dòng)Neo4j圖數(shù)據(jù)庫，創(chuàng)建搜索服務(wù)器客戶端，構(gòu)造事務(wù)事件處理器，并將所述事務(wù)事件處理器注冊到Neo4j服務(wù)中去；

利用所述事務(wù)事件處理器將圖數(shù)據(jù)節(jié)點(diǎn)和圖數(shù)據(jù)關(guān)系分別構(gòu)造成搜索服務(wù)器的文檔請求對象并存儲(chǔ)到Map中；

利用所述事務(wù)事件處理器基于所述文檔請求對象構(gòu)造搜索服務(wù)器的批量文檔請求對象，利用搜索服務(wù)器客戶端將所述批量文檔請求對象同步到搜索服務(wù)器集群中。

優(yōu)選地，所述搜索服務(wù)器采用Elasticsearch搜索服務(wù)器。

較佳地，創(chuàng)建搜索服務(wù)器客戶端，構(gòu)造事務(wù)事件處理器，并將所述事務(wù)事件處理器注冊到Neo4j服務(wù)中去的方法包括：

啟動(dòng)Neo4j圖數(shù)據(jù)庫，讀取neo4j圖數(shù)據(jù)庫的配置文件中搜索服務(wù)器集群地址和搜索服務(wù)器索引名稱；

根據(jù)搜索服務(wù)器集群地址創(chuàng)建搜索服務(wù)器客戶端；

使用搜索服務(wù)器客戶端檢查neo4j圖數(shù)據(jù)庫的配置文件中的搜索服務(wù)器索引名稱是否存在，若不存在則創(chuàng)建搜索服務(wù)器索引名稱；

依據(jù)neo4j圖數(shù)據(jù)庫的配置文件構(gòu)造事務(wù)事件處理器，并將所述事務(wù)事件處理器注冊到Neo4j服務(wù)中。

較好地，利用所述事務(wù)事件處理器將圖數(shù)據(jù)節(jié)點(diǎn)和圖數(shù)據(jù)關(guān)系分別構(gòu)造成搜索服務(wù)器的文檔請求對象并存儲(chǔ)到Map中的方法包括：

在所述事務(wù)事件處理器中創(chuàng)建Map對象，所述Map對象采用鍵集-值集的映射方式；

將Neo4j圖數(shù)據(jù)庫中的圖數(shù)據(jù)節(jié)點(diǎn)和圖數(shù)據(jù)關(guān)系分別構(gòu)造成搜索服務(wù)器的文檔請求對象；

將圖數(shù)據(jù)節(jié)點(diǎn)的實(shí)體id與索引類型構(gòu)造成的對象存儲(chǔ)為Map對象的key，和/或

將圖數(shù)據(jù)關(guān)系的實(shí)體id與索引類型構(gòu)造成的對象存儲(chǔ)為Map對象的key；