[發(fā)明專利]基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)、方法及裝置

在審

• 申請?zhí)枺?/td>: 202110472661.4
• 申請日: 2021-04-29
• 公開（公告）號: CN113127567A
• 公開（公告）日: 2021-07-16
• 發(fā)明（設(shè)計）人: 江偉;申玉;阮曙東
• 申請（專利權(quán)）人: 武漢優(yōu)品楚鼎科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25;G06Q40/04
• 代理公司: 北京路浩知識產(chǎn)權(quán)代理有限公司 11002
• 代理人: 謝志超

本發(fā)明提供一種基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)、方法及裝置，其中系統(tǒng)包括獲取模塊、存儲模塊以及計算模塊；所述獲取模塊能夠獲取金融數(shù)據(jù)，并基于分布式一致性協(xié)議存儲所述金融數(shù)據(jù)至存儲模塊；所述存儲模塊為基于分布式一致性協(xié)議構(gòu)建的分布式存儲模塊，包括第一存儲節(jié)點和第二存儲節(jié)點；所述存儲模塊能夠接收金融數(shù)據(jù)并存儲至第二存儲節(jié)點；所述計算模塊能夠通過第一存儲節(jié)點只讀地調(diào)取存儲在第二存儲節(jié)點的金融數(shù)據(jù)，并根據(jù)設(shè)定的計算方法進行計算。本發(fā)明通過將計算和存儲分離設(shè)計，提高了系統(tǒng)可擴展性；通過分布式設(shè)計，提高了針對基于分布式存儲的金融數(shù)據(jù)計算適應(yīng)性，適用場景更為全面。

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

本發(fā)明涉及金融數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)、方法及裝置。

背景技術(shù)

在金融領(lǐng)域中，金融財務(wù)數(shù)據(jù)種類繁多，例如利潤表、資產(chǎn)負債表、現(xiàn)金流量表等等，且每個表科目眾多。對于量化交易以及智能選股，對各類金融數(shù)據(jù)以及行情數(shù)據(jù)的衍生計算和分析，有助于用戶開發(fā)和優(yōu)化交易策略，從而為買賣決策提供相關(guān)參考指標。

一項現(xiàn)有技術(shù)公開了一種財務(wù)報表整合方法和設(shè)備，該方法包括：獲取每個企業(yè)的指定類型的財務(wù)報表；針對每個指定類型的財務(wù)報表，根據(jù)預(yù)設(shè)的標準行號與行名稱集的對應(yīng)關(guān)系，確定該指定類型的財務(wù)報表中各個行名稱對應(yīng)的標準行號，其中，同一行名稱集中存儲至少一個屬于同一屬性的行名稱；將該指定類型的財務(wù)報表中各個行名稱對應(yīng)的原始行號更改為各個行名稱對應(yīng)的標準行號；將更改為標準行號后的各個指定類型的財務(wù)報表保存到同一表格，得到整合后的財務(wù)報表。

雖然該現(xiàn)有技術(shù)能夠從一定程度上降低開發(fā)復(fù)雜度以及查詢的工作量，也在一定程度上提高了用戶進行財務(wù)數(shù)據(jù)查詢的便捷性和效率。但仍然存在著現(xiàn)有技術(shù)中普遍存在的問題，即：

傳統(tǒng)金融數(shù)據(jù)存儲于通用關(guān)系型數(shù)據(jù)庫中，例如MySql、Orcale等。這些數(shù)據(jù)庫要么存在單點問題，要么授權(quán)部署和運維難度大。通用關(guān)系型數(shù)據(jù)庫主要為通用場景做優(yōu)化，而金融數(shù)據(jù)具有自身的特點(時間序列，周期性)，例如在計算場景中，金融數(shù)據(jù)經(jīng)常要計算TTM(Trailing Twelve Months)類數(shù)據(jù)，而傳統(tǒng)數(shù)據(jù)庫不直接支持這類場景。

綜上所述，為解決金融數(shù)據(jù)在計算和存儲上的問題，提供一種基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)、方法及裝置具有較高的實用價值和意義。

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

針對現(xiàn)有技術(shù)存在的問題，本發(fā)明實施例提供一種基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)、方法及裝置。

本發(fā)明提供一種基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)，包括獲取模塊、存儲模塊以及計算模塊；

所述獲取模塊能夠獲取金融數(shù)據(jù)，并基于分布式一致性協(xié)議存儲所述金融數(shù)據(jù)至存儲模塊；

所述存儲模塊為基于分布式一致性協(xié)議構(gòu)建的分布式存儲模塊，包括第一存儲節(jié)點和第二存儲節(jié)點；所述存儲模塊能夠接收金融數(shù)據(jù)并存儲至第二存儲節(jié)點；

所述計算模塊能夠通過第一存儲節(jié)點只讀地調(diào)取存儲在第二存儲節(jié)點的金融數(shù)據(jù)，并根據(jù)設(shè)定的計算方法進行計算。

根據(jù)本發(fā)明提供的基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)，所述分布式一致性協(xié)議包括Raft協(xié)議；所述第二存儲節(jié)點對應(yīng)于Raft協(xié)議中的領(lǐng)導(dǎo)者leader；所述第一存儲節(jié)點為基于Raft協(xié)議引入的復(fù)制者Replicator；

所述復(fù)制者Replicator不參與Raft日志復(fù)制或者選舉；所述復(fù)制者Replicator能夠在設(shè)定的時間節(jié)點從領(lǐng)導(dǎo)者leader處同步日志并回放。

根據(jù)本發(fā)明提供的基于分布式存儲的金融數(shù)據(jù)計算系統(tǒng)：

所述存儲模塊采用列存結(jié)構(gòu)，所述列存結(jié)構(gòu)是指金融數(shù)據(jù)中每個字段單獨存儲，每一列中的數(shù)據(jù)類型一致；

所述計算模塊基于SIMD指令集，利用列存結(jié)構(gòu)的金融數(shù)據(jù)進行計算；