CN114329242A - A method and system for repairing K-line in real time - Google Patents

Abstract

The invention provides a method and a system for repairing K lines in real time, which relate to the technical field of market data processing, and comprise the following steps: s1, storing the third party K line data in real time and providing a K line repair interface; s2, calling a K line repair interface, and sending a GET request, wherein the GET request is an HTTP request method; and S3, starting the K line repair service system and completing the repair of the K line, so that the K line of the whole market code is repaired rapidly in batch in real time, and the K line is recovered to be normal.

Description

Translated fromChinese

一种实时修复K线的方法及系统A method and system for repairing K-line in real time

技术领域technical field

本发明涉及行情数据处理技术领域，具体的，本发明涉及一种实时修复K线的方法及系统。The invention relates to the technical field of market data processing, and in particular, the invention relates to a method and system for repairing K-line in real time.

背景技术Background technique

在股票市场中，K线是一种表现股市及期货市场价格趋势的图形，K线一般是由实时行情计算而来的，如果实时行情数据正常，那么计算得来的K线也是正常的。但有些情况下，实时行情出现异常时，比如数据商下发了错误的数据、数据商服务异常、本地的行情解码异常等等，则会导致K线计算错误，或者K线缺失；而且是整个股票市场的数千只代码的K线都有异常，严重影响市场交易。K线无法自我修复，人工修复难度大，此时必须使用第三方的K线数据完成K线数据修复。In the stock market, the K-line is a graph showing the price trend of the stock market and the futures market. The K-line is generally calculated from the real-time market. If the real-time market data is normal, then the calculated K-line is also normal. However, in some cases, when the real-time market is abnormal, for example, the data provider sends the wrong data, the data provider's service is abnormal, the local market decoding is abnormal, etc., it will cause the K-line calculation error, or the K-line is missing; The K-lines of thousands of symbols in the stock market are abnormal, which seriously affects market transactions. The K-line cannot be repaired by itself, and manual repair is difficult. At this time, the third-party K-line data must be used to complete the K-line data repair.

发明内容SUMMARY OF THE INVENTION

为了克服现有技术的不足，本发明提供了一种实时修复K线的方法及系统，以解决上述的技术问题。In order to overcome the deficiencies of the prior art, the present invention provides a method and system for repairing the K-line in real time, so as to solve the above-mentioned technical problems.

本发明解决其技术问题所采用的技术方法是：一种实时修复K线的方法，其改进之处在于：包括以下的步骤：S1、实时存储第三方K线数据，提供K线修复接口；S2、调用K线修复接口，发送GET请求，GET请求是一种HTTP请求方法；S3、K线修复服务系统启动并完成K线的修复。The technical method adopted by the present invention to solve the technical problem is: a method for repairing the K-line in real time, and its improvement lies in: comprising the following steps: S1, storing third-party K-line data in real time, and providing a K-line repair interface; S2 . Call the K-line repair interface and send a GET request, which is an HTTP request method; the S3, K-line repair service system starts and completes the K-line repair.

在上述方法中，所述步骤S1，包括以下的步骤：In the above method, the step S1 includes the following steps:

S11、通过同步程序，实时把第三方的K线数据，以特定的数据格式同步到Mongodb中，Mongodb是一种开源的非关系型数据库；S11. Through the synchronization program, the third-party K-line data is synchronized to Mongodb in a specific data format in real time. Mongodb is an open source non-relational database;

S12、基本面数据服务系统调用Beego库，启动HTTP服务，提供市场所有股票代码的查询服务，Beego是一种基于Golang实现的开源HTTP框架；S12. The fundamental data service system calls the Beego library, starts the HTTP service, and provides query services for all stock symbols in the market. Beego is an open source HTTP framework based on Golang;

S13、K线读写服务系统调用Kafka客户端库，连接Kafka，消费Kafka中的行情数据，生产K线，同时调用Beego库，启动HTTP服务，提供K线的查询和修改服务，Kafka是一种高吞吐量的分布式发布订阅消息系统；S13. The K-line reading and writing service system calls the Kafka client library, connects to Kafka, consumes the market data in Kafka, produces K-line, calls the Beego library at the same time, starts the HTTP service, and provides K-line query and modification services. Kafka is a kind of High-throughput distributed publish-subscribe messaging system;

S14、K线修复服务系统调用Beego库，启动HTTP服务，提供K线修复接口。S14. The K-line repair service system calls the Beego library, starts the HTTP service, and provides the K-line repair interface.

在上述方法中，所述步骤13中，Kafka中的行情数据，通过以下的步骤获取：In the above method, in step 13, the market data in Kafka is obtained through the following steps:

行情解码服务系统通过网络实时接收交易所的原始行情数据；The market decoding service system receives the original market data of the exchange in real time through the network;

把原始行情数据解码为自定义的行情数据格式；Decode the original market data into a custom market data format;

将自定义的行情数据格式转化为Pb数据格式，发送到Kafka。Convert the custom market data format to Pb data format and send it to Kafka.

在上述方法中，所述步骤S2中，所述GET请求的参数包括市场类型、开始日期和结束日期。In the above method, in step S2, the parameters of the GET request include market type, start date and end date.

在上述方法中，所述步骤S3，包括以下的步骤：In the above method, the step S3 includes the following steps:

S31、K线修复服务系统收到所述GET请求后，解析出参数，该参数包括市场类型、开始日期和结束日期；S31. After receiving the GET request, the K-line repair service system parses out parameters, where the parameters include market type, start date and end date;

S32、K线修复服务系统调用Mongodb客户端库，连接到Mongodb，查询第三方实时K线数据；S32. The K-line repair service system calls the Mongodb client library, connects to Mongodb, and queries the third-party real-time K-line data;

S33、K线修复服务系统调用基本面数据服务系统的HTTP接口，查询市场的所有股票代码；S33. The K-line repair service system invokes the HTTP interface of the fundamental data service system to query all stock symbols in the market;

S34、K线修复服务系统依次遍历所述的所有股票代码，查询第三方实时K线数据，K线读写服务系统将该三方实时K线数据写到K线文件；S34. The K-line repair service system traverses all the stock symbols in turn, inquires the third-party real-time K-line data, and the K-line reading and writing service system writes the third-party real-time K-line data to the K-line file;

S35、修复完成，K线修复服务系统返回HTTP结果。S35 , the repair is completed, and the K-line repair service system returns an HTTP result.

在上述方法中，所述步骤S34，包括以下的步骤：In the above method, the step S34 includes the following steps:

S341、K线修复服务系统遍历所述的所有股票代码，以股票代码、开始日期和结束日期作为查询条件，从Mongodb查询出第三方实时K线数据；S341. The K-line repair service system traverses all the stock codes, and uses the stock code, start date and end date as query conditions to query the third-party real-time K-line data from Mongodb;

S342、K线修复服务系统调用K线读写服务系统的K线修改接口，将第三方实时K线数据以POST请求通过K线修改接口发送给K线读写服务系统；S342. The K-line repair service system calls the K-line modification interface of the K-line reading and writing service system, and sends the third-party real-time K-line data to the K-line reading and writing service system through the K-line modification interface as a POST request;

S343、K线读写服务系统收到所述POST请求数据后，根据POST请求数据中的股票代码、开始日期和结束日期，将每一个实时K线数据写入到K线文件。S343. After receiving the POST request data, the K-line reading and writing service system writes each real-time K-line data to the K-line file according to the stock code, start date and end date in the POST request data.

本发明还提供了一种实时修复K线的系统，包括基本面数据服务系统、K线读写服务系统和K线修复服务系统，The invention also provides a real-time repairing K-line system, including a fundamental plane data service system, a K-line reading and writing service system, and a K-line repairing service system,

基本面数据服务系统用于调用Beego库，启动HTTP服务，提供市场所有股票代码的查询服务；The fundamental data service system is used to call the Beego library, start the HTTP service, and provide query services for all stock symbols in the market;

K线修复服务系统用于调用Beego库，启动HTTP服务，提供K线修复接口；在收到修复K线的GET请求后，解析出参数，该参数包括市场类型、开始日期和结束日期；调用Mongodb客户端库，连接到Mongodb，查询第三方实时K线数据；调用基本面数据服务系统的HTTP接口，查询市场的所有股票代码；遍历所述的所有股票代码，以股票代码、开始日期和结束日期作为查询条件，从Mongodb查询出第三方实时K线数据；调用K线读写服务系统的K线修改接口，将第三方实时K线数据以POST请求通过K线修改接口发送给K线读写服务系统；并在K线修复完成后返回HTTP结果；The K-line repair service system is used to call the Beego library, start the HTTP service, and provide the K-line repair interface; after receiving the GET request for repairing the K-line, it parses out the parameters, which include the market type, start date and end date; call Mongodb Client library, connect to Mongodb, query third-party real-time K-line data; call the HTTP interface of the fundamental data service system to query all stock symbols in the market; traverse all the stock symbols described, with the stock symbol, start date and end date As a query condition, query the third-party real-time K-line data from Mongodb; call the K-line modification interface of the K-line reading and writing service system, and send the third-party real-time K-line data to the K-line reading and writing service as a POST request through the K-line modification interface system; and return the HTTP result after the K-line repair is completed;

K线读写服务系统用于调用Kafka客户端库，连接Kafka，消费Kafka中的行情数据，生产K线，同时调用Beego库，启动HTTP服务，提供K线的查询和修改服务；收到所述POST请求数据后，根据POST请求数据中的股票代码、开始日期和结束日期，将每一个实时K线数据写入到K线文件。The K-line reading and writing service system is used to call the Kafka client library, connect to Kafka, consume market data in Kafka, produce K-line, and at the same time call the Beego library, start the HTTP service, and provide K-line query and modification services; After the POST request data, write each real-time K-line data to the K-line file according to the stock code, start date and end date in the POST request data.

在上述系统中，还包括行情解码服务系统，行情解码服务系统用于通过网络实时接收交易所的原始行情数据，把原始行情数据解码为自定义的行情数据格式，并将自定义的行情数据格式转化为Pb数据格式，发送到Kafka。The above system also includes a market price decoding service system, which is used to receive the original market data of the exchange through the network in real time, decode the original market data into a custom market data format, and convert the customized market data format. Convert to Pb data format and send to Kafka.

本发明的有益效果是：通过Mongodb实时存放第三方K线，通过HTTP服务提供K线修复接口，实现了快速批量的实时修复整个市场代码的K线，使K线恢复正常。The beneficial effects of the invention are: store third-party K-line in real time through Mongodb, provide K-line repair interface through HTTP service, realize the real-time repair of K-line of the entire market code in batches, and restore the K-line to normal.

附图说明Description of drawings

附图1为本发明的一种实时修复K线的方法的流程图。FIG. 1 is a flowchart of a method for repairing K-line in real time according to the present invention.

具体实施方式Detailed ways

下面结合附图和实施例对本发明进一步说明。The present invention will be further described below with reference to the accompanying drawings and embodiments.

以下将结合实施例和附图对本发明的构思、具体结构及产生的技术效果进行清楚、完整地描述，以充分地理解本发明的目的、特征和效果。显然，所描述的实施例只是本发明的一部分实施例，而不是全部实施例，基于本发明的实施例，本领域的技术人员在不付出创造性劳动的前提下所获得的其他实施例，均属于本发明保护的范围。另外，专利中涉及到的所有联接/连接关系，并非单指构件直接相接，而是指可根据具体实施情况，通过添加或减少联接辅件，来组成更优的联接结构。本发明创造中的各个技术特征，在不互相矛盾冲突的前提下可以交互组合。The concept, specific structure and technical effects of the present invention will be clearly and completely described below with reference to the embodiments and accompanying drawings, so as to fully understand the purpose, characteristics and effects of the present invention. Obviously, the described embodiments are only a part of the embodiments of the present invention, rather than all the embodiments. Based on the embodiments of the present invention, other embodiments obtained by those skilled in the art without creative efforts are all within the scope of The scope of protection of the present invention. In addition, all the coupling/connection relationships involved in the patent do not mean that the components are directly connected, but refer to a better coupling structure by adding or reducing coupling accessories according to the specific implementation. Various technical features in the present invention can be combined interactively on the premise of not contradicting each other.

参照图1所示，本发明的一种实时修复K线的方法，包括以下的步骤：Referring to Fig. 1, a method for repairing K-line in real time of the present invention comprises the following steps:

S1、实时存储第三方K线数据，提供K线修复接口；S1. Store third-party K-line data in real time, and provide a K-line repair interface;

具体的，包括如下步骤：Specifically, it includes the following steps:

S11、通过Python语言编写的同步程序，实时把第三方的K线数据，以特定的数据格式同步到Mongodb中，Mongodb是一种开源的非关系型数据库，在本发明中，用于实时存放第三方K线数据，为K线修复服务系统提供K线数据源；S11. Through the synchronization program written in the Python language, the third-party K-line data is synchronized to Mongodb in a specific data format in real time. Mongodb is an open source non-relational database. In the present invention, it is used for real-time storage of the first Three-party K-line data, providing K-line data source for K-line repair service system;

S12、基本面数据服务系统调用Beego库，启动HTTP服务，对外提供市场所有股票代码的查询服务，Beego是一种基于Golang实现的开源HTTP框架；S12. The fundamental data service system calls the Beego library, starts the HTTP service, and provides query services for all stock symbols in the market. Beego is an open source HTTP framework based on Golang;

S13、K线读写服务系统调用Kafka客户端库，连接Kafka，消费Kafka中的行情数据，生产K线，同时K线读写服务系统的另一个协程调用Beego库，启动HTTP服务，提供K线的查询和修改服务，Kafka是一种高吞吐量的分布式发布订阅消息系统，在本发明中作为消息中间件，存放实时行情；S13. The K-line reading and writing service system calls the Kafka client library, connects to Kafka, consumes the market data in Kafka, and produces K-line. At the same time, another coroutine of the K-line reading and writing service system calls the Beego library, starts the HTTP service, and provides K-line. Kafka is a high-throughput distributed publish-subscribe message system, and in the present invention, as a message middleware, it stores real-time market conditions;

所述Kafka中的行情数据通过如下方式获得：行情解码服务系统通过网络实时接收交易所的原始行情数据，然后把原始行情数据解码为自定义的行情数据格式，最后转化为Pb数据格式，发送到Kafka，Pb即protobuf，一种Google开源的实现数据自动序列化和反序列化的机制；The market data in Kafka is obtained in the following way: the market decoding service system receives the original market data of the exchange in real time through the network, then decodes the original market data into a custom market data format, and finally converts it into a Pb data format and sends it to Kafka, Pb stands for protobuf, a Google open source mechanism for automatic data serialization and deserialization;

S14、K线修复服务系统调用Beego库，启动HTTP服务，提供K线修复接口。S14. The K-line repair service system calls the Beego library, starts the HTTP service, and provides the K-line repair interface.

S2、管理员调用K线修复服务系统提供的K线修复接口，发送GET请求，所述GET请求的参数包括市场类型、开始日期和结束日期，开始日期和结束日期用于确定修复哪一个时间区间的K线，GET请求是一种HTTP请求方法。S2. The administrator invokes the K-line repair interface provided by the K-line repair service system, and sends a GET request. The parameters of the GET request include market type, start date and end date. The start date and end date are used to determine which time interval to repair. The K-line, GET request is an HTTP request method.

S3、K线修复服务系统启动并完成K线的修复；S3. K-line repair service system starts and completes the repair of K-line;

具体的，包括以下的步骤：Specifically, it includes the following steps:

S31、K线修复服务系统收到所述GET请求后，解析出参数，该参数包括市场类型、开始日期和结束日期；S31. After receiving the GET request, the K-line repair service system parses out parameters, where the parameters include market type, start date and end date;

S32、K线修复服务系统调用Mongodb客户端库，连接到Mongodb，查询第三方实时K线数据；S32. The K-line repair service system calls the Mongodb client library, connects to Mongodb, and queries the third-party real-time K-line data;

S33、K线修复服务系统调用基本面数据服务系统的HTTP接口，查询市场的所有股票代码；S33. The K-line repair service system invokes the HTTP interface of the fundamental data service system to query all stock symbols in the market;

S34、K线修复服务系统依次遍历步骤S33中所述的所有股票代码，查询第三方实时K线数据，K线读写服务系统将该三方实时K线数据写到K线文件；S34, the K-line repair service system traverses all the stock symbols described in step S33 in turn, inquires the third-party real-time K-line data, and the K-line reading and writing service system writes the third-party real-time K-line data to the K-line file;

具体的，所述步骤S34，包括如下步骤：Specifically, the step S34 includes the following steps:

S341、K线修复服务系统遍历所述的所有股票代码，以股票代码、开始日期和结束日期作为查询条件，从Mongodb查询出第三方实时K线数据；S341. The K-line repair service system traverses all the stock codes, and uses the stock code, start date and end date as query conditions to query the third-party real-time K-line data from Mongodb;

S342、K线修复服务系统调用K线读写服务系统的K线修改接口，将第三方实时K线数据以POST请求通过K线修改接口发送给K线读写服务系统，POST请求是一种HTTP请求方法；S342. The K-line repair service system calls the K-line modification interface of the K-line reading and writing service system, and sends the third-party real-time K-line data to the K-line reading and writing service system through the K-line modification interface as a POST request. The POST request is a kind of HTTP request method;

S343、K线读写服务系统收到所述POST请求数据后，根据POST请求数据中的股票代码、开始日期和结束日期，将每一个实时K线数据写入到K线文件；S343. After receiving the POST request data, the K-line reading and writing service system writes each real-time K-line data to the K-line file according to the stock code, start date and end date in the POST request data;

S35、修复完成，K线修复服务系统返回HTTP结果，实现了快速批量的实时修复整个市场代码的K线，使K线恢复正常。S35. After the repair is completed, the K-line repair service system returns HTTP results, which realizes quick batch repair of the K-line of the entire market code in real time, and restores the K-line to normal.

本发明还提供了一种实时修复K线的系统，包括基本面数据服务系统、K线读写服务系统和K线修复服务系统，The invention also provides a real-time repairing K-line system, including a fundamental plane data service system, a K-line reading and writing service system, and a K-line repairing service system,

基本面数据服务系统用于调用Beego库，启动HTTP服务，提供市场所有股票代码的查询服务；The fundamental data service system is used to call the Beego library, start the HTTP service, and provide query services for all stock symbols in the market;

K线修复服务系统用于调用Beego库，启动HTTP服务，提供K线修复接口；在收到修复K线的GET请求后，解析出参数，该参数包括市场类型、开始日期和结束日期；调用Mongodb客户端库，连接到Mongodb，查询第三方实时K线数据；调用基本面数据服务系统的HTTP接口，查询市场的所有股票代码；遍历所述的所有股票代码，以股票代码、开始日期和结束日期作为查询条件，从Mongodb查询出第三方实时K线数据；调用K线读写服务系统的K线修改接口，将第三方实时K线数据以POST请求通过K线修改接口发送给K线读写服务系统；并在K线修复完成后返回HTTP结果；The K-line repair service system is used to call the Beego library, start the HTTP service, and provide the K-line repair interface; after receiving the GET request for repairing the K-line, it parses out the parameters, which include the market type, start date and end date; call Mongodb Client library, connect to Mongodb, query third-party real-time K-line data; call the HTTP interface of the fundamental data service system to query all stock symbols in the market; traverse all the stock symbols described, with the stock symbol, start date and end date As a query condition, query the third-party real-time K-line data from Mongodb; call the K-line modification interface of the K-line reading and writing service system, and send the third-party real-time K-line data to the K-line reading and writing service as a POST request through the K-line modification interface system; and return the HTTP result after the K-line repair is completed;

K线读写服务系统用于调用Kafka客户端库，连接Kafka，消费Kafka中的行情数据，生产K线，同时调用Beego库，启动HTTP服务，提供K线的查询和修改服务；收到所述POST请求数据后，根据POST请求数据中的股票代码、开始日期和结束日期，将每一个实时K线数据写入到K线文件。至此，K线修复完成，K线修复服务系统返回HTTP结果，实现了快速批量的实时修复整个市场代码的K线，使K线恢复正常。The K-line reading and writing service system is used to call the Kafka client library, connect to Kafka, consume market data in Kafka, produce K-line, and at the same time call the Beego library, start the HTTP service, and provide K-line query and modification services; After the POST request data, write each real-time K-line data to the K-line file according to the stock code, start date and end date in the POST request data. At this point, the K-line repair is completed, and the K-line repair service system returns HTTP results, which realizes rapid batch repair of the K-line of the entire market code in real time, and restores the K-line to normal.

进一步的，本发明的一种实时修复K线的系统还包括行情解码服务系统，行情解码服务系统用于通过网络实时接收交易所的原始行情数据，把原始行情数据解码为自定义的行情数据格式，并将自定义的行情数据格式转化为Pb数据格式，发送到Kafka。Further, a real-time K-line repairing system of the present invention further includes a market quotation decoding service system, and the quotation decoding service system is used to receive the original quotation data of the exchange through the network in real time, and decode the original quotation data into a self-defined quotation data format. , and convert the custom market data format into Pb data format and send it to Kafka.

本发明通过Mongodb实时存放第三方K线，通过HTTP服务提供K线修复接口，实现了快速批量的实时修复整个市场代码的K线，使K线恢复正常。The invention stores the third-party K-line in real time through Mongodb, provides the K-line repair interface through HTTP service, realizes the real-time repair of the K-line of the entire market code in batches, and restores the K-line to normal.

以上是对本发明的较佳实施进行了具体说明，但本发明创造并不限于所述实施例，熟悉本领域的技术人员在不违背本发明精神的前提下还可做出种种的等同变形或替换，这些等同的变形或替换均包含在本申请权利要求所限定的范围内。The above is a specific description of the preferred implementation of the present invention, but the present invention is not limited to the described embodiments, and those skilled in the art can also make various equivalent deformations or replacements on the premise that does not violate the spirit of the present invention , these equivalent modifications or substitutions are all included within the scope defined by the claims of the present application.

Claims (8)

1. A method for repairing K lines in real time is characterized in that: the method comprises the following steps:

s1, storing the third party K line data in real time and providing a K line repair interface;

s2, calling a K line repair interface, and sending a GET request, wherein the GET request is an HTTP request method;

and S3, starting the K line repair service system and completing the repair of the K line.

2. The method for repairing K-lines in real time as claimed in claim 1, wherein: the step S1 includes the following steps:

s11, synchronizing the K line data of the third party to Mongodb in real time in a specific data format through a synchronization program, wherein the Mongodb is an open-source non-relational database;

s12, calling a Beego library by a basic plane data service system, starting HTTP service, and providing query service of all stock codes in the market, wherein Beego is an open source HTTP frame realized based on Golang;

s13, the K line read-write service system calls a Kafka client library, connects Kafka, consumes market data in Kafka, produces K lines, calls a Beego library at the same time, starts HTTP service and provides query and modification service of the K lines, and the Kafka is a high-throughput distributed publishing and subscribing message system;

and S14, calling a Beego library by the K-line repair service system, starting HTTP service and providing a K-line repair interface.

3. The method for repairing K-lines in real time as claimed in claim 2, wherein: in the step 13, the market data in Kafka is obtained through the following steps:

the market decoding service system receives the original market data of the exchange in real time through the network;

decoding the original market data into a custom market data format;

and converting the self-defined market data format into a Pb data format, and sending the Pb data format to Kafka.

4. The method for repairing K-lines in real time as claimed in claim 3, wherein: in step S2, the parameters of the GET request include a market type, a start date, and an end date.

5. The method for repairing K lines in real time as claimed in claim 4, wherein: the step S3 includes the following steps:

s31, after receiving the GET request, the K line repair service system analyzes parameters, wherein the parameters comprise market types, start dates and end dates;

s32, the K line repairing service system calls a Mongodb client library, connects to the Mongodb and inquires real-time K line data of a third party;

s33, the K-line repair service system calls an HTTP interface of the basic surface data service system to inquire all stock codes of the market;

s34, the K-line repairing service system sequentially traverses all stock codes, inquires the real-time K-line data of a third party, and the K-line reading and writing service system writes the real-time K-line data of the third party to a K-line file;

and S35, completing the repair, and returning the HTTP result by the K-line repair service system.

6. The method for repairing K lines in real time as claimed in claim 5, wherein: the step S34 includes the following steps:

s341, the K line repairing service system traverses all stock codes, takes the stock codes, the starting date and the ending date as query conditions, and queries the real-time K line data of the third party from Mongobb;

s342, the K line repairing service system calls a K line modification interface of the K line reading and writing service system, and sends the real-time K line data of the third party to the K line reading and writing service system through the K line modification interface according to the POST request;

and S343, after receiving the POST request data, the K-line read-write service system writes each piece of real-time K-line data into the K-line file according to the stock codes, the starting date and the ending date in the POST request data.

7. A system for repairing K lines in real time is characterized in that: comprises a basic plane data service system, a K line read-write service system and a K line repair service system,

the basic surface data service system is used for calling a Beego library, starting HTTP service and providing query service of all stock codes in the market;

the K line repair service system is used for calling the Beego library, starting HTTP service and providing a K line repair interface; after a GET request for repairing a K line is received, parameters are analyzed, wherein the parameters comprise market types, starting dates and ending dates; calling a Mongodb client library, connecting to Mongodb, and inquiring the real-time K line data of a third party; calling an HTTP interface of a basic surface data service system to inquire all stock codes of the market; traversing all the stock codes, and inquiring the real-time K line data of the third party from Mongobb by taking the stock codes, the starting date and the ending date as inquiry conditions; calling a K line modification interface of the K line read-write service system, and sending the third-party real-time K line data to the K line read-write service system through the K line modification interface according to a POST request; and returning an HTTP result after the K line is repaired;

the K line read-write service system is used for calling a Kafka client library, connecting the Kafka client library, consuming market data in the Kafka client library, producing a K line, calling a Beego library at the same time, starting HTTP service and providing inquiry and modification service of the K line; and after receiving the POST request data, writing each piece of real-time K-line data into a K-line file according to the stock codes, the starting date and the ending date in the POST request data.

8. The system for repairing K-wires in real time as claimed in claim 7, wherein: the system also comprises a quotation decoding service system, wherein the quotation decoding service system is used for receiving the original quotation data of the exchange in real time through the network, decoding the original quotation data into a self-defined quotation data format, converting the self-defined quotation data format into a Pb data format and sending the Pb data format to Kafka.

Images