CN111260227A - 业务数据源处理方法、装置、计算机设备和存储介质 - Google Patents

Abstract

本申请涉及一种业务数据源处理方法、装置、计算机设备和存储介质。所述方法包括：接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分。根据预设周期内与每个业务指标分别对应的各业务数据源的得分，统计各业务数据源分别对应的分数结果。将满足预设条件的分数结果所对应的业务数据源作为目标数据源。当目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将分数值与目标数据源的分数结果进行比对，得到比对结果。根据比对结果，确定下一个预设周期内待启用的业务数据源。采用本方法能够提升业务数据处理效率。

Description

业务数据源处理方法、装置、计算机设备和存储介质

技术领域

本申请涉及计算机技术领域，特别是涉及一种业务数据源处理方法、装置、计算机设备和存储介质。

背景技术

随着计算机技术的发展，业务数据包括有丰富的数据信息量，业务数据可直接反应相关的业务情况。业务数据消费系统可通过业务数据触发生成交易订单。因此，业务数据的消费者对获取到的业务数据的高效性有着越来越高的要求，而选择一个速度快的业务数据源是提高业务数据处理效率的关键。目前，传统的业务数据源处理方法主要是选择一个最快的业务数据源作为固定的主业务数据源，当固定的主业务数据源发生故障时，备用的业务数据源可替换发生故障的主业务数据源。

然而，目前的业务数据源处理方法，在选择业务数据源的过程中不够灵活，使得选择最快的业务数据源不准确，进而导致业务数据处理效率低。

发明内容

基于此，有必要针对上述技术问题，提供一种能够提升业务数据处理效率的业务数据源处理方法、装置、计算机设备和存储介质。

一种业务数据源处理方法，所述方法包括：

接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

一种业务数据源处理装置，所述装置包括：

接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现以下步骤：

接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现以下步骤：

接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

上述业务数据源处理方法、装置、计算机设备和存储介质，通过与业务数据相关联的业务指标，根据业务指标到达业务数据接收设备的先后顺序，对各业务数据源进行打分。通过对各业务数据源进行打分得到与各业务数据源对应的分数结果，确定发送业务数据最快的业务数据源作为目标数据源。进而根据预设条件判断目标数据源是否满足替换当前启用的业务数据源的条件，若满足则将目标数据源替换当前启用的业务数据源。这样，在保证业务数据接收稳定的前提下，确保业务数据接收到业务数据的速度最快，进而提升了业务数据处理效率。

附图说明

图1为一个实施例中业务数据源处理方法的应用场景图；

图2为一个实施例中业务数据源处理方法的流程示意图；

图3为一个实施例中业务数据源的选择框图；

图4为另一个实施例中业务数据源处理方法的应用场景图；

图5为一个实施例中业务数据源处理装置的结构框图；

图6为另一个实施例中业务数据源处理装置的结构框图；

图7为一个实施例中计算机设备的内部结构图。

具体实施方式

为了使本申请的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本申请进行进一步详细说明。应当理解，此处描述的具体实施例仅仅用以解释本申请，并不用于限定本申请。

本申请提供的业务数据源处理方法，可以应用于如图1所示的应用环境中。该应用环境包括多于一个的业务数据源服务器102和业务数据源处理服务器104。业务数据源服务器102和业务数据源处理服务器104通过网络进行通信。其中，业务数据源服务器102和业务数据源处理服务器104，可以用独立的服务器或者是多个服务器组成的服务器集群来实现。本领域技术人员可以理解，图1中示出的应用环境，仅仅是与本申请方案相关的部分场景，并不构成对本申请方案应用环境的限定。

业务数据源处理服务器104接收业务数据源服务器102发送的、与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源服务器102的得分。业务数据源处理服务器104根据预设周期内与每个业务指标分别对应的各业务数据源服务器102的得分，统计各业务数据源服务器102分别对应的分数结果。业务数据源处理服务器104将满足预设条件的分数结果所对应的业务数据源服务器102作为目标数据源。当目标数据源不是当前启用的业务数据源服务器102时，业务数据源处理服务器104获取当前启用的业务数据源服务器102所对应的分数值，并将分数值与目标数据源的分数结果进行比对，得到比对结果。业务数据源处理服务器104根据比对结果，确定下一个预设周期内待启用的业务数据源服务器102。

在一个实施例中，如图2所示，提供了一种业务数据源处理方法，以该方法应用于图1中的业务数据源处理服务器104为例进行说明，包括以下步骤：

S202，接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分。

其中，业务数据是企业在业务运营的过程中产生的数据，比如，业务数据可以是证券公司在证券交易过程中产生的交易数据。业务指标是确定各业务数据唯一性的指标。业务数据源是存储有业务数据的计算机设备，用于将业务数据发送至接收业务数据的计算机设备。

具体地，业务数据源处理系统中部署有多于一条的数据传输线路，多于一条的数据传输线路对接不同的业务数据源，且所有数据传输线路都传输相同的业务数据，并可对业务数据做相同逻辑的数据处理。每条数据传输线路可各自传输业务数据，并各自与业务数据源处理服务器对接。每一条业务数据对应有各自的业务指标，业务数据源可将业务数据和业务指标进行绑定，并在同一个数据通道下发。业务数据源处理服务器可接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分。

在一个实施例中，业务数据可以是证券交易中的交易数据，具体可以是来自不同的证券交易所的行情数据，行情数据可用于揭示证券的当前交易情况。比如，证券交易所内每只证券当前委托买卖盘信息、最新成交价、成交数量、成交金额等，其中，证券可以是股票、基金和债券等，本实施例在此不做限定。

在一个实施例中，当业务数据是来自不同的证券交易所的行情数据时，业务指标具体可以是逐笔行情数据的消息序号、快照行情某一只证券的快照行情产生时间或者累计成交量等。

在一个实施例中，业务数据具体可以是证券交易场景中的行情数据，行情数据可来自同一个证券交易所的多于一个不同行情数据源服务器所发布的相同的行情数据。行情数据源服务器具体可以通过镜像实现行情数据的采集，而镜像采集的行情数据所对应的行情数据源服务器发送行情数据的速度有快有慢，行情数据源处理服务器根据接收到指标数据的时间顺序，确定相应的行情数据源服务器得分。

S204，根据预设周期内与每个业务指标分别对应的各业务数据源的得分，统计各业务数据源分别对应的分数结果。

具体地，各业务数据源发送业务数据的速度快慢是不断变化的，因此需要定时对当前启用的业务数据源进行更新。业务数据源处理服务器可设定预设周期作为业务数据源更新的周期，业务数据源处理服务器可根据预设周期内与每个业务指标分别对应的各业务数据源的得分，统计各业务数据源分别对应的分数结果。

在一个实施例中，业务数据具体可以是证券交易场景中的行情数据，业务数据源具体可以是行情源。如图3所示，行情数据处理系统中包括行情源1、行情源2、行情源处理服务器以及行情消费端。行情源1和行情源2中存储有相同的行情数据和指标数据。行情源可将行情数据与指标数据进行关联，并在同一个数据通道发送给行情源处理服务器，使得行情源处理服务器可根据接收到的指标数据判断是否接收到行情数据。在一个统计周期内，当行情接收端每次接收到未出现过的指标数据时，给对应的行情源记1分，在统计周期结束时，行情源1得分为30分，行情源2得分为50分。

S206，将满足预设条件的分数结果所对应的业务数据源作为目标数据源。

其中，目标数据源是在预设周期内发送业务数据速度最快的数据源，用于替换当前启用的业务数据源。

具体地，各业务数据源分别对应有各自的分数结果，业务数据源处理服务器可预先设定预设条件，比如，预设条件具体可以是分数结果为最高分。进而可将各业务数据源分别对应有各自的分数结果与预设条件进行分析，将满足预设条件的分数结果所对应的业务数据源作为目标数据源。

S208，当目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将分数值与目标数据源的分数结果进行比对，得到比对结果。

具体地，目标数据源是预设周期内发送业务数据最快的数据源，目标数据源具体可以是当前启用的业务数据源，也可以不是当前启用的业务数据源。当前启用的业务数据源对应的有分数值，当目标数据源不是当前启用的业务数据源时，业务数据源处理服务器获取当前启用的业务数据源所对应的分数值，并将分数值与目标数据源的分数结果进行比对，得到比对结果。

S210，根据比对结果，确定下一个预设周期内待启用的业务数据源。

具体地，业务数据源在每一个预设周期更新一次，在当前的预设周期内存在一个当前启用的业务数据源，当前启用的业务数据源是根据前一个预设周期确定的业务数据源。进而业务数据源处理服务器可根据比对结果，确定下一个预设周期内待启用的业务数据源。

在一个实施例中，业务数据具体可以是证券交易场景中的行情数据，业务数据源具体可以是行情源。如图4所示，行情数据处理系统中包括行情源1、行情源2、行情源3、行情源处理服务器以及行情消费端。行情源处理服务器可从行情源1、行情源2和行情源3中选择行情数据发送最快的一个行情源作为统计周期内当前启用的行情源。行情源处理服务器在接收到行情数据后可将行情数据发送至行情消费端，行情消费端可基于接收到的行情数据进行相应的业务处理。其中，行情消费端可以是业务消费系统。业务消费系统是基于业务数据进行业务处理的系统，用于触发生成交易订单。比如，业务消费系统可以是证券交过场景中的策略系统和量化交易系统。

上述业务数据源处理方法中，通过与业务数据相关联的业务指标，根据业务指标到达业务数据接收设备的先后顺序，对各业务数据源进行打分。通过对各业务数据源进行打分得到与各业务数据源对应的分数结果，确定发送业务数据最快的业务数据源作为目标数据源。进而根据预设条件判断目标数据源是否满足替换当前启用的业务数据源的条件，若满足则将目标数据源替换当前启用的业务数据源。这样，在保证业务数据接收稳定的前提下，确保业务数据接收到业务数据的速度最快，进而提升了业务数据处理效率。

在一个实施例中，业务数据源处理方法具体还包括：当目标数据源为当前启用的业务数据源时，直接将目标数据源作为下一个预设周期内的待启用的业务数据源。

具体地，目标数据源是预设周期内发送业务数据最快的数据源，目标数据源具体可以是当前启用的业务数据源，也可以不是当前启用的业务数据源。当目标数据源为当前启用的业务数据源时，业务数据源处理服务器可直接将目标数据源作为下一个预设周期内的待启用的业务数据源，可以理解，当目标数据源为当前启用的业务数据源时，下一个预设周期可不替换业务数据源。

上述实施例中，通过对当前启用的业务数据源进行判断，当目标数据源为当前启用的业务数据源时，对当前启用的业务数据源不进行切换，保证了下一个预设周期内的待启用的业务数据源仍为发送业务数据最快的业务数据源。

在一个实施例中，步骤S202，也就是接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分的步骤之前，业务数据源处理方法具体还包括：根据预设业务需求，确定处理业务数据源的预设周期；在预设周期开始时，监测各业务数据源在上一个预设周期内的得分状态，并将各业务数据源在上一个预设周期内的得分清零。

具体地，统计业务数据源的得分状态是在一个设定的时间段内进行的，业务数据源处理服务器可根据预设业务需求，确定处理业务数据源的预设周期。每一个预设周期内各业务数据源分别都对应有各自的得分。在预设周期开始时，业务数据源处理服务器可监测各业务数据源在上一个预设周期内的得分状态，并将各业务数据源在上一个预设周期内的得分清零。

上述实施例中，在一个新的预设周期开始前，将上一个预设周期内的得分清零，避免了上一个预设周期内的得分对新的预设周期的分数结果的干扰，提高了下一个预设周期分数结果统计的精确度。

在一个实施例中，步骤S202，也就是接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分的步骤，具体包括：获取业务数据传输指令；业务数据传输指令包括业务数据和业务指标，且业务数据和业务指标关联；根据业务数据和业务指标关联所对应的关联结果，对业务数据传输指令进行解析，提取业务数据对应的业务指标；当业务指标首次出现，且业务指标所对应的下一个业务指标未出现时，确定发送业务指标的业务数据源的得分。

其中，业务数据传输指令是一种计算机传输指令，用于将业务数据从业务数据源传输至业务数据源处理服务器。

具体地，业务数据源中存储有业务数据和业务指标，业务数据源可将业务数据和业务指标进行关联，得到关联结果，进而根据关联结果可生成业务数据传输指令，并将业务数据传输指令发送至业务数据源处理服务器。业务数据源处理服务器可接收业务数据传输指令，进而根据业务数据和业务指标关联所对应的关联结果，对业务数据传输指令进行解析，提取业务数据对应的业务指标。业务数据源处理服务器可对业务指标进行实时监测。当监测到业务指标首次出现，且业务指标所对应的下一个业务指标未出现时，业务数据源处理服务器可确定发送业务指标的业务数据源的得分。

上述实施例中，通过将业务数据和业务指标关联在同一个数据通道下发，使得业务数据和业务指标能同一时间到达业务数据源处理服务器，进而业务数据源处理服务器可根据接收到业务指标的情况，确定对应的业务数据源的得分，便于得分统计。

在一个实施例中，步骤S204，也就是根据预设周期内与每个业务指标分别对应的各业务数据源的得分，统计各业务数据源分别对应的分数结果的步骤，具体包括：根据各业务数据源的得分的生成时间，在预设周期内分别将与每个业务指标分别对应的各业务数据源的得分进行累加运算，得到与各业务数据源对应的累加结果；根据累加结果，确定预设周期内各业务数据源分别对应的分数结果。

具体地，各业务数据源发送业务指标的速度不同，使得业务数据源处理服务器接收到业务指标的时间也不同，进而各业务数据源的得分的生成时间也不同。业务数据源服务器可根据各业务数据源的得分的生成时间，在预设周期内分别将与每个业务指标分别对应的各业务数据源的得分进行累加运算，得到与各业务数据源对应的累加结果。进而业务数据源服务器可根据累加结果，确定预设周期内各业务数据源分别对应的分数结果。

上述实施例中，通过在预设周期内将与每个业务指标分别对应的各业务数据源的得分进行累加运算，使得各业务数据源都对应一个分数结果，进而使得业务数据源的选择更加便捷和准确。

在一个实施例中，比对结果包括目标数据源的分数结果与当前启用的业务数据源所对应的分数值的比值，步骤210，也就是根据比对结果，确定下一个预设周期内待启用的业务数据源的步骤，具体包括：当比值小于预设数值时，确定当前启用的业务数据源为下一个预设周期内待启用的业务数据源；当比值不小于预设数值时，确定目标数据源为下一个预设周期内待启用的业务数据源。

具体地，比对结果包括目标数据源的分数结果与当前启用的业务数据源所对应的分数值的比值。业务数据源处理服务器可提前设定一个预设数值，业务数据源处理服务器可将比值与预设数值进行比较。当比值小于预设数值时，业务数据源处理服务器可确定当前启用的业务数据源为下一个预设周期内待启用的业务数据源，可以理解，当比值小于预设数值时，不做切换。当比值不小于预设数值时，业务数据源处理服务器可确定目标数据源为下一个预设周期内待启用的业务数据源。

在一个实施例中，目标数据源的分数结果与当前启用的业务数据源所对应的分数值的比值为m，且预设数值取值为1，其中，m为可配置数值。当m取值为1时，表示始终选择最快的业务数据源。当m取值为大于1时，表示只有当统计出来的分数结果比当前启用的业务数据源的分数值高于1个比例系数时，才切换业务数据源。

上述实施例中，通过设定一个预设数值，将比值和预设数值进行比较，进而确定下一个预设周期内待启用的业务数据源。这样，避免频繁切换业务数据源，使得在保证业务数据处理效率的同时，保证了系统的稳定性。

在一个实施例中，业务数据源处理方法还包括：实时监测各业务数据源的运行状态；在监测到当前启用的业务数据源的运行状态为故障时，获取前一个预设周期内各业务数据源分别对应的分数结果；根据分数结果，确定最高分数对应的业务数据源作为替换业务数据源，并将替换业务数据源替换故障的业务数据源。

具体地，各业务数据源在运行时可能会出现故障，为了保证系统正常运作，业务数据源处理服务器可实时监测各业务数据源的运行状态。由于每一个预设周期内各业务数据源都分别对应有各自的分数结果，因此在监测到当前启用的业务数据源的运行状态为故障时，业务数据源处理服务器可获取前一个预设周期内各业务数据源分别对应的分数结果。进而业务数据源处理服务器可根据分数结果，确定最高分数对应的业务数据源作为替换业务数据源，并将替换业务数据源替换故障的业务数据源。

在一个实施例中，业务数据源的运行状态为故障，具体可以是业务数据在网络传输过程中出现了网络故障，从而导致了业务数据在网络中传输失败。还可以是数据传输线路中的计算机设备，比如服务器中的组件发生了故障，使得服务器停止工作，从而导致业务数据在数据传输线路中传输失败。

上述实施例中，通过对当前启用的业务数据源的运行状态进行实时监控，在当前启用的业务数据源故障时，能及时选择最快的业务数据源替换掉当前启用的故障的业务数据源，进一步提升了业务数据处理效率。

应该理解的是，虽然图2的各个步骤按照顺序依次显示，但是这些步骤并不是必然按照顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，这些步骤可以以其它的顺序执行。而且，上述图2中的至少一部分步骤可以包括多个子步骤或者多个阶段，这些子步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，这些子步骤或者阶段的执行顺序也不必然是依次进行，而是可以与其它步骤或者其它步骤的子步骤或者阶段的至少一部分轮流或者交替地执行。

在一个实施例中，如图5所示，提供了一种业务数据源处理装置500，包括：接收模块501、统计模块502、确定模块503和获取模块504，其中：

接收模块501，用于接收与各业务数据分别对应的业务指标，并根据接收到的业务指标的时间顺序，确定发送业务指标的业务数据源的得分。

统计模块502，用于根据预设周期内与每个业务指标分别对应的各业务数据源的得分，统计各业务数据源分别对应的分数结果。

确定模块503，用于将满足预设条件的分数结果所对应的业务数据源作为目标数据源。

获取模块504，用于当目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将分数值与目标数据源的分数结果进行比对，得到比对结。

确定模块503还用于根据比对结果，确定下一个预设周期内待启用的业务数据源。

在一个实施例中，接收模块501还用于获取业务数据传输指令；业务数据传输指令包括业务数据和业务指标，且业务数据和业务指标关联；根据业务数据和业务指标关联所对应的关联结果，对业务数据传输指令进行解析，提取业务数据对应的业务指标；当业务指标首次出现，且业务指标所对应的下一个业务指标未出现时，确定发送业务指标的业务数据源的得分。

在一个实施例中，统计模块502还用于根据各业务数据源的得分的生成时间，在预设周期内分别将与每个业务指标分别对应的各业务数据源的得分进行累加运算，得到与各业务数据源对应的累加结果；根据累加结果，确定预设周期内各业务数据源分别对应的分数结果。

在一个实施例中，确定模块503还用于当目标数据源为当前启用的业务数据源时，直接将目标数据源作为下一个预设周期内的待启用的业务数据源。

在一个实施例中，确定模块503还用于根据预设业务需求，确定处理业务数据源的预设周期。

在一个实施例中，确定模块503还用于当比值小于预设数值时，确定当前启用的业务数据源为下一个预设周期内待启用的业务数据源；当比值不小于预设数值时，确定目标数据源为下一个预设周期内待启用的业务数据源。

在一个实施例中，确定模块503还用于根据分数结果，确定最高分数对应的业务数据源作为替换业务数据源，并将替换业务数据源替换故障的业务数据源。

在一个实施例中，获取模块504还用于在监测到当前启用的业务数据源的运行状态为故障时，获取前一个预设周期内各业务数据源分别对应的分数结果。

参考图6，在一个实施例中，业务数据源处理装置500还包括监测模块505，其中：

监测模块505，用于在所述预设周期开始时，监测各业务数据源在上一个预设周期内的得分状态，并将各业务数据源在上一个预设周期内的得分清零。

在一个实施例中，监测模块505还用于实时监测各业务数据源的运行状态。

上述业务数据源处理装置，通过与业务数据相关联的业务指标，根据业务指标到达业务数据接收设备的先后顺序，对各业务数据源进行打分。通过对各业务数据源进行打分得到与各业务数据源对应的分数结果，确定发送业务数据最快的业务数据源作为目标数据源。进而根据预设条件判断目标数据源是否满足替换当前启用的业务数据源的条件，若满足则将目标数据源替换当前启用的业务数据源。这样，在保证业务数据接收稳定的前提下，确保业务数据接收到业务数据的速度最快，进而提升了业务数据处理效率。

关于业务数据源处理装置的具体限定可以参见上文中对于业务数据源处理方法的限定，在此不再赘述。上述业务数据源处理装置中的各个模块可全部或部分通过软件、硬件及其组合来实现。上述各模块可以硬件形式内嵌于或独立于计算机设备中的处理器中，也可以以软件形式存储于计算机设备中的存储器中，以便于处理器调用执行以上各个模块对应的操作。

在一个实施例中，提供了一种计算机设备，该计算机设备可以是上述图1中的业务数据源处理服务器104，其内部结构图可以如图7所示。该计算机设备包括通过系统总线连接的处理器、存储器、网络接口和数据库。其中，该计算机设备的处理器用于提供计算和控制能力。该计算机设备的存储器包括非易失性存储介质、内存储器。该非易失性存储介质存储有操作系统、计算机程序和数据库。该内存储器为非易失性存储介质中的操作系统和计算机程序的运行提供环境。该计算机设备的数据库用于存储业务数据源处理数据。该计算机设备的网络接口用于与外部的终端通过网络连接通信。该计算机程序被处理器执行时以实现一种业务数据源处理方法。

本领域技术人员可以理解，图7中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。

在一个实施例中，提供了一种计算机设备，包括存储器和处理器，存储器存储有计算机程序，计算机程序被处理器执行时，使得处理器执行上述业务数据源处理方法的步骤。此处业务数据源处理方法的步骤可以是上述各个实施例的业务数据源处理方法中的步骤。

在一个实施例中，提供了一种计算机可读存储介质，存储有计算机程序，计算机程序被处理器执行时，使得处理器执行上述业务数据源处理方法的步骤。此处业务数据源处理方法的步骤可以是上述各个实施例的业务数据源处理方法中的步骤。

本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的计算机程序可存储于一非易失性计算机可读取存储介质中，该计算机程序在执行时，可包括如上述各方法的实施例的流程。其中，本申请所提供的各实施例中所使用的对存储器、存储、数据库或其它介质的任何引用，均可包括非易失性和/或易失性存储器。非易失性存储器可包括只读存储器(ROM)、可编程ROM(PROM)、电可编程ROM(EPROM)、电可擦除可编程ROM(EEPROM)或闪存。易失性存储器可包括随机存取存储器(RAM)或者外部高速缓冲存储器。作为说明而非局限，RAM以多种形式可得，诸如静态RAM(SRAM)、动态RAM(DRAM)、同步DRAM(SDRAM)、双数据率SDRAM(DDRSDRAM)、增强型SDRAM(ESDRAM)、同步链路(Synchlink)DRAM(SLDRAM)、存储器总线(Rambus)直接RAM(RDRAM)、直接存储器总线动态RAM(DRDRAM)、以及存储器总线动态RAM(RDRAM)等。

以上实施例的各技术特征可以进行任意的组合，为使描述简洁，未对上述实施例中的各个技术特征所有可能的组合都进行描述，然而，只要这些技术特征的组合不存在矛盾，都应当认为是本说明书记载的范围。

以上所述实施例仅表达了本申请的几种实施方式，其描述较为具体和详细，但并不能因此而理解为对发明专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，在不脱离本申请构思的前提下，还可以做出若干变形和改进，这些都属于本申请的保护范围。因此，本申请专利的保护范围应以所附权利要求为准。

Claims (10)

1.一种业务数据源处理方法，包括：

接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

2.根据权利要求1所述的方法，其特征在于，所述方法还包括：

当所述目标数据源为当前启用的业务数据源时，直接将所述目标数据源作为下一个预设周期内的待启用的业务数据源。

3.根据权利要求1所述的方法，其特征在于，所述接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分之前，所述方法还包括：

根据预设业务需求，确定处理业务数据源的预设周期；

在所述预设周期开始时，监测各业务数据源在上一个预设周期内的得分状态，并将各业务数据源在上一个预设周期内的得分清零。

4.根据权利要求1所述的方法，其特征在于，所述接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分，包括：

获取业务数据传输指令；所述业务数据传输指令包括业务数据和业务指标，且所述业务数据和所述业务指标关联；

根据所述业务数据和所述业务指标关联所对应的关联结果，对所述业务数据传输指令进行解析，提取所述业务数据对应的业务指标；

当所述业务指标首次出现，且所述业务指标所对应的下一个业务指标未出现时，确定发送所述业务指标的业务数据源的得分。

5.根据权利要求1所述的方法，其特征在于，所述根据预设周期内，与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果，包括：

根据各所述业务数据源的得分的生成时间，在预设周期内分别将与每个业务指标分别对应的各所述业务数据源的得分进行累加运算，得到与各所述业务数据源对应的累加结果；

根据所述累加结果，确定预设周期内各所述业务数据源分别对应的分数结果。

6.根据权利要求1所述的方法，其特征在于，所述比对结果包括所述目标数据源的分数结果与当前启用的业务数据源所对应的分数值的比值，所述根据所述比对结果，确定下一个预设周期内待启用的业务数据源，包括：

当所述比值小于预设数值时，确定当前启用的业务数据源为下一个预设周期内待启用的业务数据源；

当所述比值不小于预设数值时，确定所述目标数据源为下一个预设周期内待启用的业务数据源。

7.根据权利要求1至6中任一项所述的方法，其特征在于，所述方法还包括：

实时监测各所述业务数据源的运行状态；

在监测到当前启用的业务数据源的运行状态为故障时，获取前一个预设周期内各所述业务数据源分别对应的分数结果；

根据所述分数结果，确定最高分数对应的业务数据源作为替换业务数据源，并将所述替换业务数据源替换故障的业务数据源。

8.一种业务数据源处理装置，其特征在于，所述装置包括：

接收模块，用于接收与各业务数据分别对应的业务指标，并根据接收到的所述业务指标的时间顺序，确定发送所述业务指标的业务数据源的得分；

统计模块，用于根据预设周期内与每个业务指标分别对应的各所述业务数据源的得分，统计各所述业务数据源分别对应的分数结果；

确定模块，用于将满足预设条件的分数结果所对应的业务数据源作为目标数据源；

获取模块，用于当所述目标数据源不是当前启用的业务数据源时，获取当前启用的业务数据源所对应的分数值，并将所述分数值与所述目标数据源的分数结果进行比对，得到比对结果；

确定模块还用于根据所述比对结果，确定下一个预设周期内待启用的业务数据源。

9.一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至7中任一项所述方法的步骤。

10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。

Images