[發(fā)明專利]一種基于MongoDB的證券實時交易關(guān)聯(lián)分析的方法

在審

• 申請?zhí)枺?/td>: 201611062583.6
• 申請日: 2016-11-25
• 公開（公告）號: CN106776837A
• 公開（公告）日: 2017-05-31
• 發(fā)明（設(shè)計）人: 鄭銳韜;李勇波;孫傲冰;季統(tǒng)凱;張恒
• 申請（專利權(quán)）人: 國云科技股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06Q40/04
• 代理公司: 廣東莞信律師事務(wù)所44332
• 代理人: 余倫

1.一種基于MongoDB的證券實時交易關(guān)聯(lián)分析的方法，其特征在于，包括以下步驟：

步驟1：將MongoDB當作一個高效的數(shù)據(jù)存取空間，搭建一個獨立的MongoDB或由多個MongoDB形成的集群用于證券實時數(shù)據(jù)獲取后高效的存取操作；

步驟2：獲取各個證券的詳細信息，用于進行證券數(shù)據(jù)實時獲取與進行分析時使用；

步驟3：設(shè)計一個永久存儲表，每次獲取的數(shù)據(jù)存儲在該表，用于后續(xù)的數(shù)據(jù)確認分析；同時設(shè)計一個在半個小時內(nèi)有效的臨時存儲表，用于進行短時間內(nèi)的各關(guān)聯(lián)分析的數(shù)據(jù)獲??；

步驟4：設(shè)置間隔獲取時間，前述的間隔點上獲取實時證券數(shù)據(jù)，并經(jīng)過去重處理，把獲取的實時數(shù)據(jù)分別存儲到永久存儲表及臨時存儲表上；

步驟5：通過查詢臨時存儲表上的數(shù)據(jù)，分析獲取在多種時間段內(nèi)的各證券的表現(xiàn)形式，對于各時間段內(nèi)同時出現(xiàn)的各種異常，輸出相應(yīng)的異動類型與證券編碼，形成實時的證券實時關(guān)聯(lián)分析，用于進行證券交易的指導(dǎo)參考。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述的存取操作，包括：存儲并讀取其歷史數(shù)據(jù)與臨時數(shù)據(jù)，對于歷史數(shù)據(jù)大的，搭建MongoDB集群，并對歷史數(shù)據(jù)按日期進行分區(qū)讀??；

所述的詳細信息，包括編碼、名稱、股本、大股東占比等信息。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述步驟3，具體步驟為：

步驟一：在MongoDB上設(shè)計一個永久存儲表，用于存儲不斷累積的證券實時交易的歷史數(shù)據(jù)，按日期時間進行分區(qū)，并設(shè)計存儲在不同的數(shù)據(jù)存儲空間上；對于部署在集群，可增加證券編碼的哈希存儲，通過證券編碼將不同的證券數(shù)據(jù)哈希存儲在多臺服務(wù)器上；

步驟二：對于實時的證券數(shù)據(jù)分析，在MongoDB上設(shè)計一個臨時存儲表，用于存儲半個小時內(nèi)的證券數(shù)據(jù)，利用MongoDB的TTL索引，在一個時間列上建立一個TTL索引，在臨時表上設(shè)置半個小時時間，該時間點自動刪除臨時表的數(shù)據(jù)。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述步驟3，具體步驟為：

步驟一：在MongoDB上設(shè)計一個永久存儲表，用于存儲不斷累積的證券實時交易的歷史數(shù)據(jù)，按日期時間進行分區(qū)，并設(shè)計存儲在不同的數(shù)據(jù)存儲空間上；對于部署在集群，可增加證券編碼的哈希存儲，通過證券編碼將不同的證券數(shù)據(jù)哈希存儲在多臺服務(wù)器上；

步驟二：對于實時的證券數(shù)據(jù)分析，在MongoDB上設(shè)計一個臨時存儲表，用于存儲半個小時內(nèi)的證券數(shù)據(jù)，利用MongoDB的TTL索引，在一個時間列上建立一個TTL索引，在臨時表上設(shè)置半個小時時間，該時間點自動刪除臨時表的數(shù)據(jù)。

5.根據(jù)權(quán)利要求1-4任一項所述的方法，其特征在于，所述的步驟4，具體步驟為：

步驟一：在獲取相關(guān)的證券編寫及前綴基礎(chǔ)上調(diào)用證券實時數(shù)據(jù)接口，所有的證券數(shù)據(jù)，按已有的詳細數(shù)據(jù)，完成實時數(shù)據(jù)調(diào)用的初始化，運行證券數(shù)據(jù)實時獲取程序，通過線程并發(fā)的形式把數(shù)據(jù)發(fā)送到接口上獲取數(shù)據(jù)；

步驟二：多線程獲取的證券實時數(shù)據(jù)，包括當天的開盤價、最高價、最低價、實時價、成交量、成交額、買五檔的數(shù)量及價格、賣五檔的數(shù)量及價格，各獲取數(shù)據(jù)的線程在獲取了各個證券的實時信息后，進行解析，同時查詢獲取的實時信息是否與最近的一次獲取的信息是相同的，相同表示已經(jīng)存在的，不再進行保存；

步驟三：經(jīng)過去重后的證券實時數(shù)據(jù)，分別保存在永久存儲表與臨時存儲表，用于后續(xù)的歷史查詢與實時關(guān)聯(lián)分析；

所述的證券實時數(shù)據(jù)獲取的間隔獲取時間可配置為每3秒或5秒獲取一次，對于獲取頻率高的數(shù)據(jù)，存儲和系統(tǒng)的處理需高要求。