本发明涉及信息处理,尤其涉及一种行情数据处理方法及其装置、存储介质、程序产品。
背景技术:
1、随着信息技术快速发展,对数据分析及传输领域的实时性及性能要求也越来越高。以虚拟资源市场为例,基于可用性的考虑,行情系统一般会连接交易所或数据商等多路行情源,以保证获取准确的行情数据。另外,对于每路行情源,均会接入完整的行情应用服务,在使用过程中,启用其中一个行情应用服务,并获取对应的行情源的行情数据,如果当前使用的行情源出现链路故障而需要进行容灾切换时,启用另外的行情应用服务,并获取对应的行情源的行情数据,达到为用户提供准确有效的行情服务的目的。
2、但是,当由于行情源出现链路故障而进行容灾切换时,需要先停用当前的行情应用服务,然后启用另外的行情应用服务,从而造成容灾切换时效性低的问题。
技术实现思路
1、以下是对本文详细描述的主题的概述。本概述并非是为了限制权利要求的保护范围。
2、本发明实施例提供了一种行情数据处理方法及其装置、存储介质、程序产品,能够提高容灾切换的时效性,从而改善用户的使用体验。
3、一方面,本发明实施例提供了一种行情数据处理方法,包括以下步骤:
4、从多个行情数据源获取行情数据;
5、对多个所述行情数据源的所述行情数据进行基于市场类型与数据源的数据分类,得到不同市场类型下各个所述行情数据源的分类行情数据;
6、根据各个所述市场类型所支持的业务特点确定各个所述市场类型的市场特征信息;
7、根据各个所述市场类型的所述市场特征信息确定各个所述市场类型的数据取优策略;
8、根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据。
9、另一方面,本发明实施例还提供了一种行情数据处理装置,包括:
10、行情获取单元,用于从多个行情数据源获取行情数据;
11、行情分类单元,用于对多个所述行情数据源的所述行情数据进行基于市场类型与数据源的数据分类,得到不同市场类型下各个所述行情数据源的分类行情数据;
12、特征确定单元,用于根据各个所述市场类型所支持的业务特点确定各个所述市场类型的市场特征信息;
13、策略确定单元,用于根据各个所述市场类型的所述市场特征信息确定各个所述市场类型的数据取优策略;
14、行情取优单元,用于根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据。
15、可选地,所述行情分类单元还用于:
16、对多个所述行情数据源的所述行情数据进行市场类型分类,得到多个市场行情数据;
17、对所有所述市场行情数据进行数据源分类,得到不同市场类型下各个所述行情数据源的分类行情数据。
18、可选地,所述行情分类单元还用于:
19、根据各个所述行情数据所属的市场类型,为各个所述行情数据配置市场类型标号;
20、根据所述市场类型标号对多个所述行情数据源的所述行情数据进行市场类型分类,得到多个市场行情数据。
21、可选地,所述行情分类单元还用于:
22、根据各个所述市场行情数据所属的数据源类型,为各个所述市场行情数据配置数据源类型标号;
23、根据所述数据源类型标号对所有所述市场行情数据进行数据源类型分类,得到不同市场类型下各个所述行情数据源的分类行情数据。
24、可选地,所述数据取优策略至少包括如下之一:
25、基于时间优先的数据取优;
26、或者,基于消息号优先的数据取优;
27、或者,基于消息号连续优先的数据取优;
28、或者,基于目标类型数据优先的数据取优。
29、可选地,当所述数据取优策略包括基于消息号优先的数据取优,所述行情取优单元还用于:
30、对于每个所述市场类型,获取当前市场类型下各个所述行情数据源的所述分类行情数据的消息号;
31、在当前市场类型下所有所述行情数据源的所述分类行情数据的所述消息号中,确定目标消息号,其中,所述目标消息号为与前一次得到的最优行情数据所对应的消息号呈递进关系的消息号;
32、将所述目标消息号所对应的所述分类行情数据确定为当前市场类型的最优行情数据。
33、可选地,当所述数据取优策略包括基于消息号连续优先的数据取优,所述行情取优单元还用于:
34、对于每个所述市场类型,获取当前市场类型下各个所述行情数据源的所述分类行情数据的消息号;
35、将预设时间段内所述消息号连续的所述行情数据源作为目标行情数据源;
36、将所述目标行情数据源的所述分类行情数据确定为当前市场类型的最优行情数据。
37、可选地,当所述数据取优策略包括基于目标类型数据优先的数据取优,所述行情取优单元还用于:
38、对于每个所述市场类型,获取当前市场类型下各个所述行情数据源的所述分类行情数据的目标类型数据;
39、将所述目标类型数据发生变化的所述分类行情数据确定为当前市场类型的最优行情数据。
40、可选地,当所述数据取优策略包括基于时间优先的数据取优,所述行情取优单元还用于:
41、对于每个所述市场类型,获取当前市场类型下各个所述行情数据源的所述分类行情数据的时间戳;
42、在当前市场类型下所有所述行情数据源的所述分类行情数据的所述时间戳中,将数值最大的所述时间戳作为目标时间戳;
43、将所述目标时间戳所对应的所述分类行情数据确定为当前市场类型的最优行情数据。
44、可选地,所述行情获取单元还用于:
45、从多个行情数据源获取初始行情数据;
46、对所述初始行情数据进行协议转换,得到协议转换后的行情数据。
47、可选地,所述行情数据处理装置还包括:
48、行情整理单元,用于将所述最优行情数据整理成目标数据图表;
49、行情发送单元,用于将所述目标数据图表发送给目标对象。
50、另一方面,本发明实施例还提供了一种行情数据处理装置,包括:
51、至少一个处理器;
52、至少一个存储器,用于存储至少一个程序;
53、当至少一个所述程序被至少一个所述处理器执行时实现如前面所述的行情数据处理方法。
54、另一方面,本发明实施例还提供了一种计算机可读存储介质,其中存储有处理器可执行的计算机程序,所述处理器可执行的计算机程序被处理器执行时用于实现如前面所述的行情数据处理方法。
55、另一方面,本发明实施例还提供了一种计算机程序产品,包括计算机程序或计算机指令,所述计算机程序或所述计算机指令存储在计算机可读存储介质中,行情数据处理装置的处理器从所述计算机可读存储介质读取所述计算机程序或所述计算机指令,所述处理器执行所述计算机程序或所述计算机指令,使得所述行情数据处理装置执行如前面所述的行情数据处理方法。
56、本发明实施例至少包括以下有益效果:在从多个行情数据源获取行情数据之后,对多个行情数据源的行情数据进行基于市场类型与数据源的数据分类,得到不同市场类型下各个行情数据源的分类行情数据,能够节省后续的数据加工耗时,提高数据处理效率;然后,根据各个市场类型所支持的业务特点确定各个市场类型的市场特征信息,并根据各个市场类型的市场特征信息确定各个市场类型的数据取优策略,由于各个市场类型的数据取优策略是根据各个市场类型的市场特征信息而确定的,而各个市场类型的市场特征信息是根据各个市场类型所支持的业务特点而确定的,因此各个市场类型的数据取优策略能够适配各个市场类型,从而能够提高后续的数据取优的准确性;在确定了各个市场类型的数据取优策略之后,根据各个市场类型的数据取优策略对各个市场类型的所有行情数据源的分类行情数据进行数据取优,得到各个市场类型的最优行情数据,由于在进行数据切换的过程中,仅需对多个分类行情数据进行数据取优,并不需要切换行情数据源的数据链路,也不需要停用当前的行情应用服务以及启用另外的行情应用服务,因此能够提高容灾切换的时效性,从而改善用户的使用体验,而且,由于不需要对行情应用服务进行切换,因此不需要针对每路行情源部署一个行情应用服务,从而能够有效降低资源成本。
57、本发明的其它特征和优点将在随后的说明书中阐述,并且,部分地从说明书中变得显而易见,或者通过实施本发明而了解。本发明的目的和其他优点可通过在说明书、权利要求书以及附图中所特别指出的结构来实现和获得。
1.一种行情数据处理方法,其特征在于,包括以下步骤:
2.根据权利要求1所述的行情数据处理方法,其特征在于,所述对多个所述行情数据源的所述行情数据进行基于市场类型与数据源的数据分类,得到不同市场类型下各个所述行情数据源的分类行情数据,包括:
3.根据权利要求2所述的行情数据处理方法,其特征在于,所述对多个所述行情数据源的所述行情数据进行市场类型分类,得到多个市场行情数据,包括:
4.根据权利要求2所述的行情数据处理方法,其特征在于,所述对所有所述市场行情数据进行数据源分类,得到不同市场类型下各个所述行情数据源的分类行情数据,包括:
5.根据权利要求1所述的行情数据处理方法,其特征在于,所述数据取优策略至少包括如下之一:
6.根据权利要求5所述的行情数据处理方法,其特征在于,当所述数据取优策略包括基于消息号优先的数据取优,所述根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据,包括:
7.根据权利要求5所述的行情数据处理方法,其特征在于,当所述数据取优策略包括基于消息号连续优先的数据取优,所述根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据,包括:
8.根据权利要求5所述的行情数据处理方法,其特征在于,当所述数据取优策略包括基于目标类型数据优先的数据取优,所述根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据,包括:
9.根据权利要求5所述的行情数据处理方法,其特征在于,当所述数据取优策略包括基于时间优先的数据取优,所述根据各个所述市场类型的所述数据取优策略对各个所述市场类型的所有所述行情数据源的所述分类行情数据进行数据取优,得到各个所述市场类型的最优行情数据,包括:
10.根据权利要求1所述的行情数据处理方法,其特征在于,所述从多个行情数据源获取行情数据,包括:
11.根据权利要求1所述的行情数据处理方法,其特征在于,所述方法还包括:
12.一种行情数据处理装置,其特征在于,包括:
13.一种行情数据处理装置,其特征在于,包括:
14.一种计算机可读存储介质,其特征在于,其中存储有处理器可执行的计算机程序,所述处理器可执行的计算机程序被处理器执行时用于实现如权利要求1至11任意一项所述的行情数据处理方法。
15.一种计算机程序产品,包括计算机程序或计算机指令,其特征在于,所述计算机程序或所述计算机指令存储在计算机可读存储介质中,行情数据处理装置的处理器从所述计算机可读存储介质读取所述计算机程序或所述计算机指令,所述处理器执行所述计算机程序或所述计算机指令,使得所述行情数据处理装置执行如权利要求1至11任意一项所述的行情数据处理方法。
