[發明專利]基于Gremlin的并行擴展方法、系統、電子設備及存儲介質

在審

• 申請號: 202110721326.3
• 申請日: 2021-06-28
• 公開（公告）號: CN113535145A
• 公開（公告）日: 2021-10-22
• 發明（設計）人: 鄭天昊
• 申請（專利權）人: 北京明略軟件系統有限公司
• 主分類號: G06F8/30
• 分類號: G06F8/30
• 代理公司: 青島清泰聯信知識產權代理有限公司 37256
• 代理人: 趙燕

本發明提出一種基于Gremlin的并行擴展方法、系統、電子設備及存儲介質，其方法技術方案包括并行擴展預置步驟，在編譯器中基于JanusGraph圖擴展接口，通過Gremlin添加一parallel step，并將所述parallel下的全部點信息和邊信息添加至一集合中；執行邏輯改寫步驟，對所述Gremlin中的VertexStep、EdgeOtherStep和EdgeVertexStep進行執行邏輯的改寫，所述通過繼承所述Gremlin中的AbstractStep并重寫processNextStart()方法實現；解析攔截替換步驟，在所述Gremlin的解析階段進行攔截，當解析識別到所述parallel step時，通過改寫后的所述執行邏輯進行執行。本申請解決了現有圖的擴展方法擴展效率低下的問題。

技術領域

本發明屬于知識圖譜技術領域，尤其涉及一種基于Gremlin的并行擴展方法、系統、電子設備及存儲介質。

背景技術

近年來，隨著互聯網和社交網絡的快速發展，大規模的圖結構數據逐漸增多，例如將知識圖譜、社交網絡等信息抽象成的圖結構數據。相比于傳統的大數據處理系統，圖系統能更好地利用圖的結構信息，對圖數據的處理更為高效。隨著圖結構化數據的增多，如何高效處理大量圖結構數據成為研究的熱點。市面上現有的使用Gremlin作為圖數據遍歷語言的圖數據庫產品中，大部分都是直接使用原生的流式處理邏輯，關于圖的擴展方面沒有進行優化，使得大量數據頻繁多次請求，加大了圖數據庫的開銷，使擴展效率低下。

發明內容

本申請實施例提供了一種基于Gremlin的并行擴展方法、系統、電子設備及存儲介質，以至少解決現有圖的擴展方法擴展效率低下的問題。

第一方面，本申請實施例提供了一種基于Gremlin的并行擴展方法，包括：并行擴展預置步驟，在編譯器中基于JanusGraph圖擴展接口，通過Gremlin添加一parallel step，并將所述parallel下的全部點信息和邊信息添加至一集合中；執行邏輯改寫步驟，對所述Gremlin中的VertexStep、EdgeOtherStep和 EdgeVertexStep進行執行邏輯的改寫，所述通過繼承所述Gremlin中的 AbstractStep并重寫processNextStart()方法實現；解析攔截替換步驟，在所述 Gremlin的解析階段進行攔截，當解析識別到所述parallel step時，通過改寫后的所述執行邏輯進行執行。

優選的，所述執行邏輯改寫步驟進一步包括：VertexStep改寫步驟，通過所述JanusGraph中的一并行查詢方法進行一條件傳入操作，若返回為 Vertex.class，則執行multiQuery.getEntities方法，若返回為Edge.class，則執行multiQuery.getRelations方法。

優選的，所述執行邏輯改寫步驟進一步包括：EdgeOtherStep改寫步驟，根據判斷本端點的值來判斷需要獲取的對端點，并將全部所述對端點的ID集合作為條件傳入entityQuery.ids(ids).execute()。

優選的，所述執行邏輯改寫步驟進一步包括：EdgeVertexStep改寫步驟，根據方向進行判斷，若所述方向為IN，則獲取關系的主體ID，若所述方向為 OUT，則獲取關系的客體ID。