[發明專利]一種Elasticsearch高效檢索的方法、系統、計算機設備及存儲介質

在審

• 申請號: 202011193220.2
• 申請日: 2020-10-30
• 公開（公告）號: CN112347335A
• 公開（公告）日: 2021-02-09
• 發明（設計）人: 胡京定
• 申請（專利權）人: 銀盛支付服務股份有限公司
• 主分類號: G06F16/953
• 分類號: G06F16/953;G06F11/14
• 代理公司: 深圳市深可信專利代理有限公司 44599
• 代理人: 劉昌剛

本發明涉及一種Elasticsearch高效檢索的方法、系統、計算機設備及存儲介質，涉及風險排查技術領域，包括數據寫入和數據讀取，數據寫入時，客戶端選擇一級協調節點進行信息交互，即發送寫請求，通過路由計算確定文檔的位置，將寫請求轉發到二級協調節點上執行寫請求，執行寫請求成功后將數據備份至三級協調節點，同時，將數據返回至一級協調節點上，數據讀取時，客戶端選擇一級協調節點進行信息交互，即發送讀請求，通過路由計算確定文檔位置，將讀請求轉發至二級協調節點上執行讀請求，執行讀請求成功后將數據返回至一級協調節點上，數據最終返回至客戶端，本發明持無限擴張,能夠快速高效地進行查詢工作。

技術領域

本發明涉及風險排查技術領域，具體來說，涉及一種Elasticsearch高效檢索的方法、系統、計算機設備及存儲介質。

背景技術

隨著風險排查工作的不斷持續進行,已經積累了海量風險數據,原有的oracl數據庫,已經無法滿足海量數據的高效查詢工作,嚴重時，導致整個查詢系統的崩潰，造成數據丟失，損失較大。

發明內容

為了克服現有技術的不足，本發明的一種Elasticsearch高效檢索的方法、系統、計算機設備及存儲介質，能夠支持無線擴張，滿足海量數據高效查詢的目的。

本發明解決其技術問題所采用的技術方案是：一種Elasticsearch高效檢索的方法，其改進之處在于，包括數據寫入和數據讀取；

數據寫入步驟如下：

客戶端選擇一級協調節點進行信息交互，即發送寫請求，通過路由計算確定文檔的位置，將寫請求轉發到二級協調節點上執行寫請求，執行寫請求成功后將數據備份至三級協調節點，同時，將數據返回至與客戶端信息交互的一級協調節點上，所述一級協調節點、二級協調節點及三級協調節點均報告成功，則二級協調節點向一級協調節點報告成功，一級協調節點向客戶端報告成功；

數據讀取步驟如下：

客戶端選擇一級協調節點進行信息交互，即發送讀請求，通過路由計算確定文檔位置，將讀請求轉發至二級協調節點上執行讀請求，執行讀請求成功后將數據返回至與客戶端信息交互的一級協調節點上，數據最終返回至客戶端。

作為上述技術方案的改進，所述一級協調節點、二級協調節點以及三級協調節點均包括主分片和副本分片。

作為上述技術方案的進一步改進，數據寫入時：客戶端選擇一級協調節點進行信息交互時，通過路由計算，確定文檔屬于該一級協調節點的主分片，將寫請求轉發到二級協調節點的主分片上，并執行寫請求，執行寫請求成功時，將數據備份至三級協調節點的副本分片上，同時，將數據返回至一級協調節點的副本分片上，所述一級協調節點的副本分片、二級協調節點的副本分片及三級協調節點的副本分片均報告成功，則二級協調節點向一級協調節點報告成功，一級協調節點向客戶端報告成功。

作為上述技術方案的進一步改進，數據讀取時：客戶端選擇一級協調節點進行信息交互時，通過路由計算，確定文檔屬于二級協調節點的主分片，將讀請求轉發到二級協調節點上時，具體存入的是二級協調節點的主分片上，并執行讀請求，執行讀請求成功時，將數據返回至與客戶端信息交互的一級協調節點的副本分片上，數據最終返回至客戶端。

一種Elasticsearch高效檢索的系統，其改進之處在于，包括數據系統，所述數據系統用于接收客戶端的寫請求，確定文檔位置后執行寫請求，成功后將數據備份，并向客戶端報告成功，所述數據系統還用于接收客戶端的讀請求，確定文檔位置后執行讀請求，成功后將文檔返回至客戶端。

作為上述技術方案的進一步改進，所述數據系統包括一級協調節點、二級協調節點以及三級協調節點，所述一級協調節點、二級協調節點以及三級協調節點之間電性連接。

作為上述技術方案的進一步改進，所述一級協調節點、二級協調節點以及三級協調節點均包括主分片和副本分片。