[發明專利]一種基于實時行情的股票篩選方法及系統

在審

• 申請號: 202111497567.0
• 申請日: 2021-12-09
• 公開（公告）號: CN114331714A
• 公開（公告）日: 2022-04-12
• 發明（設計）人: 張成坤
• 申請（專利權）人: 盈立數智科技（深圳）有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04;G06F16/2458
• 代理公司: 深圳市深可信專利代理有限公司 44599
• 代理人: 彭光榮

本發明提供了一種基于實時行情的股票篩選方法及系統，涉及行情數據處理技術領域，該方法包括以下的步驟:S1、接收交易所的原始數據，提供所有代碼的財務指標數據的查詢接口；S2、更新股票的指標數據到Elasticsearch，Elasticsearch是一個分布式、高擴展、高實時的搜索與數據分析引擎；S3、調用選股接口，篩選股票后返回股票篩選結果，通過將實時行情數據及時更新到Elasticsearch，利用Elasticsearch高效的搜索功能，實現了基于實時行情的股票篩選。

技術領域

本發明涉及行情數據處理技術領域，具體的，本發明涉及一種基于實時行情的股票篩選方法及系統。

背景技術

股票有幾十至上百個指標數據，例如股價、市值、資產收益率、凈資產收益率、市盈率等等，需要根據若干項指標篩選出用戶需要的股票。

現有的技術方案，是用Mysql定期存儲股票的指標數據，但是在交易階段，股票的行情處于變化之中，Mysql中的股票指標數據無法做到實時更新，在選股過程中指標數據相對于實時行情有一定的偏差，可能會造成用戶的投資損失，無法滿足用戶需求。

發明內容

為了克服現有技術的不足，本發明提供了一種基于實時行情的股票篩選方法及系統，以解決上述的技術問題。

本發明解決其技術問題所采用的技術方法是：一種基于實時行情的股票篩選方法，其改進之處在于：包括以下的步驟：S1、接收交易所的原始數據，提供所有代碼的財務指標數據的查詢接口；S2、更新股票的指標數據到Elasticsearch，Elasticsearch是一個分布式、高擴展、高實時的搜索與數據分析引擎；S3、調用選股接口，篩選股票后返回股票篩選結果。

在上述方法中，所述步驟S1，包括以下的步驟：

S11、行情解碼服務系統從網絡接收交易所的原始數據，將數據解碼為自定義的行情數據，并且轉化成Pb數據格式，Pb即protobuf，是Google開源的實現數據自動序列化和反序列化的機制；

S12、調用Kafka客戶端庫，將Pb數據發送到Kafka，Kafka是一種高吞吐量的分布式發布訂閱消息系統；

S13、指標數據服務系統調用Beego庫，啟動HTTP服務，提供市場所有代碼的財務指標數據的查詢接口，Beego是基于Golang實現的、開源的HTTP框架，HTTP即網絡通信協議。

在上述方法中，所述步驟S2，包括以下的步驟：

S21、選股器數據服務系統向指標數據服務系統發起HTTP請求，查詢得到所有代碼的財務指標數據，以代碼為鍵，用哈希表存儲；

S22、調用Kafka客戶端庫連接Kafka，消費實時Pb數據，使用Pb庫把Pb數據解析為自定義的行情數據；

S23、以所述的自定義行情數據中的代碼為鍵，到所述哈希表中查詢，得到所述代碼的財務指標數據，將所述自定義的行情數據和所述的財務指標數據合并，得到完整的指標數據；

S24、調用Elasticsearch客戶端庫連接Elasticsearch，將所述的完整的指標數據插入到Elasticsearch中。

在上述方法中，所述步驟S3，包括以下的步驟：

S31、股票查詢服務系統調用Beego庫啟動HTTP服務，接收HTTP的選股請求，調用Json庫解析出選股參數；

S32、調用Elasticsearch客戶端庫連接Elasticsearch，使用所述的解析出的選股參數，向Elasticsearch發送搜索請求；

S33、返回搜索結果。