一种基于广告投放过程的实时预警方法、系统及计算机

摘要

本发明属于互联网广告投放技术领域，具体涉及一种基于广告投放过程的实时预警方法、系统及计算机，通过获取实时的曝光数据；根据实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；根据判断结果，进行相应的预警操作。本发明通过监控每个小时的投放量和总量的方式来对投放可能出现的问题进行预警，以便工作人员针广告投放过程中可能出现的问题对广告曝光及时作出调整。

说明书

技术领域

本发明属于互联网广告投放技术领域，具体涉及一种基于广告投放过程的实时预警方法、系统及计算机。

背景技术

在广告投放系统中，通常会存在一些告警规则，比如服务器的资源CPU，内存，磁盘等硬件资源的告警规则，但这些都是针对硬件的告警，可能也会有每天投放量情况的告警，比如是否缺量的告警，但是这些一般都是按天统计，延迟较大，因此，如何实时统计广告投放流量，并进行预警，已成为现阶段亟待解决的技术问题。

发明内容

为了解决现有技术存在的在广告投放过程中不能实时预警的问题，本发明实施例提供以下技术方案：

第一方面，一种基于广告投放过程中的实时预警方法，包括：

获取实时的曝光数据；

根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；

根据所述判断结果，进行相应的预警操作。

进一步地，所述获取实时曝光数据，包括：

提取所述曝光数据中的关键信息，根据所述关键信息合成曝光量；

根据所述曝光量，计算当前关键信息对应的曝光量。

进一步地，所述关键信息包括订单号和曝光时间。

进一步地，所述根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果，包括：

按照第一预设时间周期查询当前曝光量；

若所述当前曝光量超过预设曝光量的40％，则判断所述曝光超量。

进一步地，所述根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果，包括：

按照第二预设时间周期查询历史曝光量；

若所述历史曝光量低于预设曝光量的40％，则判断所述曝光缺量。

进一步地，所述根据所述判断结果，进行相应的预警操作，包括：

根据所述判断结果，预测曝光超量原因信息，将所述曝光超量原因信息发送至用户终端。

进一步地，所述根据所述判断结果，进行相应的预警操作，包括：

根据所述判断结果，预测曝光缺量原因信息，将所述曝光缺量原因信息发送至用户终端。

第二方面，一种基于广告投放过程中的实时预警系统，包括：

获取模块，用于获取实时的曝光数据；

判断模块，用于根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；

预警操作模块，用于根据所述判断结果，进行相应的预警操作。

进一步地，所述判断模块包括：

第一查询模块，用于按照第一预设时间周期查询当前曝光量；

曝光超量判断模块，用于若所述当前曝光量超过预设曝光量的40％，则判断所述曝光超量；

第二查询模块，按照第二预设时间周期查询历史曝光量；

曝光缺量判断模块，若所述历史曝光量低于预设曝光量的40％，则判断所述曝光缺量。

第三方面，一种计算机，包括存储器和处理器，所述存储器中存储有计算机可读指令，所述计算机可读指令被所述处理器执行时，使得所述处理器执行如上任一项所述方法的步骤。

本发明实施例提供的一种基于广告投放过程中的实时预警方法，通过获取实时的曝光数据；根据实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；根据判断结果，进行相应的预警操作。本发明通过监控每个小时的投放量和总量的方式来对投放可能出现的问题进行预警，以便工作人员针广告投放过程中可能出现的问题对广告曝光及时作出调整。

附图说明

为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1是本发明实施例中一种基于广告投放过程中的实时预警方法流程示意图。

图2是本发明实施例中一种基于广告投放过程中的实时预警系统结构示意图。

附图标记

1-获取模块；2-判断模块；2-1-第一查询模块；2-2-曝光超量判断模块；2-3-第二查询模块；2-4-曝光缺量判断模块；3-预警操作模块。

具体实施方式

为使本发明的目的、技术方案和优点更加清楚，下面将对本发明的技术方案进行详细的描述。显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动的前提下所得到的所有其它实施方式，都属于本发明所保护的范围。

如图1所示，为本发明一个实施例中一种基于广告投放过程中的实时预警方法流程示意图，包括：

步骤S101、获取实时的曝光数据；

进一步地，所述获取实时曝光数据，包括：

提取所述曝光数据中的关键信息，根据所述关键信息合成曝光量；

根据所述曝光量，计算当前关键信息对应的曝光量。

其中，所述关键信息包括订单号和曝光时间。

步骤S102、根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；

进一步地，所述根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果，包括：

按照第一预设时间周期查询当前曝光量；

若所述当前曝光量超过预设曝光量的40％，则判断所述曝光超量。

进一步地，还包括，按照第二预设时间周期查询历史曝光量；

若所述历史曝光量低于预设曝光量的40％，则判断所述曝光缺量。

步骤S103、根据所述判断结果，进行相应的预警操作。

进一步地，所述根据所述判断结果，进行相应的预警操作，包括：

根据所述判断结果，预测曝光超量原因信息，将所述曝光超量原因信息发送至用户终端。

进一步地，还包括，根据所述判断结果，预测曝光缺量原因信息，将所述曝光缺量原因信息发送至用户终端。

本发明提出了一种基于广告投放过程中的实时预警方法，通过获取实时的曝光数据；根据实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；根据判断结果，进行相应的预警操作。通过监控每个小时的投放量和总量的方式来对投放可能出现的问题进行预警，以便工作人员针广告投放过程中可能出现的问题对广告曝光及时作出调整。

该方法在实际执行前，实时的曝光统计方法可包括如下步骤：

步骤1、曝光服务器获取终端曝光请求信息；将曝光请求信息发送至kafka系统；

其中，Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。

步骤2、kafka系统将曝光数据发送至spark分布式实时计算框架；

其中，Spark是专为大规模数据处理而设计的快速通用的计算引擎。现在形成一个高速发展应用广泛的生态系统。

步骤3、spark分布式实时计算框架根据接收到的曝光数据，利用map算子通过实时计算，提取每条记录的订单号和曝光时间；

步骤4、spark分布式实时计算框架将订单号和曝光时间组合成关键信息，即得到曝光量；

步骤5、通过reduceByKey(_+_)算子，计算出当前订阅订单号和预设时间对应的曝光量；

步骤6、将步骤5的计算结果通过使用redis的increment方式，将本次计算结果加上redis已经存储的结果，得到当前订单的当前小时的曝光总量。

在告警程序查询曝光的时候，不需要临时统计每个小时的曝光量，只需要将订单和预设时间组合作为关键词，就可以快速的从redis查询到对应的曝光数。

在广告主下单的时候，会在后台系统指定一天的曝光量要求是多少，比如是240000个曝光量，然后平均分配到每个小时进行曝光,那每个小时就要求10000个曝光量。

比如，广告主要求一天的曝光量是y,每个小时的要求曝光量是x[0]...x[h],其中x[0]表示0点要求的曝光量，x[h]就表示第h小时的要求曝光量，h小于等于23，然后在redis每个订单每天的实时总曝光量用m表示,当前是第h个小时,0

超量预警:每分钟定时查询，如果m-sum(x[0]+..+x[h 1])>40％*sum(x[0]+..+x[h1])，也就是截止当前一个小时的曝光量已经超光当前小时要求的40％了，则可能是曝光统计或者曝光服务出现了问题，可以通过短信预警发送至用户终端。

缺量预警:每个小时的第1分钟查询上个小时的数据，如果m-sum(x[0]+..+x[h-1])<40％*sum(x[0]+..+x[h-1])，也就是截止前一个小时的曝光缺量达到了40％,说明需要运营关注调整,可以通过短信预警发送至用户终端。

本发明所述的基于广告投放过程中的实时预警，基于投放过程中的实时预警，通过基于spark快速计算和redis原子递增的方式计算小时曝光，然后制定合理的告警规则，能快速发现系统是否出现问题，及时解决，提高客户投放体验。

在一个实施例中，本发明还提供了一种基于广告投放过程中的实时预警系统结构图，如图2所示，包括：

获取模块1，用于获取实时的曝光数据；

判断模块2，用于根据所述实时曝光数据，判断当前曝光数量是否超过预设规则，得到判断结果；

预警操作模块3，用于根据所述判断结果，进行相应的预警操作。

进一步地，所述判断模块包括：

第一查询模块2-1，用于按照第一预设时间周期查询当前曝光量；

曝光超量判断模块2-2，用于若所述当前曝光量超过预设曝光量的40％，则判断所述曝光超量；

第二查询模块2-3，按照第二预设时间周期查询历史曝光量；

曝光缺量判断模块2-4，若所述历史曝光量低于预设曝光量的40％，则判断所述曝光缺量。

本发明所提供的一种基于广告投放过程中的实时预警系统，能够实时精确的发现系统是否存在问题，并能快速通知开发或者运营，减少不必要的损失。

本发明还提供了一种计算机，包括存储器和处理器，所述存储器中存储有计算机可读指令，所述计算机可读指令被所述处理器执行时，使得所述处理器执行如前面所述任一项所述方法的步骤。

可以理解的是，上述各实施例中相同或相似部分可以相互参考，在一些实施例中未详细说明的内容可以参见其他实施例中相同或相似的内容。

需要说明的是，在本申请的描述中，术语“第一”、“第二”等仅用于描述目的，而不能理解为指示或暗示相对重要性。此外，在本申请的描述中，除非另有说明，“多个”的含义是指至少两个。

流程图中或在此以其他方式描述的任何过程或方法描述可以被理解为，表示包括一个或更多个用于实现特定逻辑功能或过程的步骤的可执行指令的代码的模块、片段或部分，并且本申请的优选实施方式的范围包括另外的实现，其中可以不按所示出或讨论的顺序，包括根据所涉及的功能按基本同时的方式或按相反的顺序，来执行功能，这应被本申请的实施例所属技术领域的技术人员所理解。

应当理解，本申请的各部分可以用硬件、软件、固件或它们的组合来实现。在上述实施方式中，多个步骤或方法可以用存储在存储器中且由合适的指令执行系统执行的软件或固件来实现。例如，如果用硬件来实现，和在另一实施方式中一样，可用本领域公知的下列技术中的任一项或他们的组合来实现：具有用于对数据信号实现逻辑功能的逻辑门电路的离散逻辑电路，具有合适的组合逻辑门电路的专用集成电路，可编程门阵列(PGA)，现场可编程门阵列(FPGA)等。

本技术领域的普通技术人员可以理解实现上述实施例方法携带的全部或部分步骤是可以通过程序来指令相关的硬件完成，所述的程序可以存储于一种计算机可读存储介质中，该程序在执行时，包括方法实施例的步骤之一或其组合。

此外，在本申请各个实施例中的各功能单元可以集成在一个处理模块中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个模块中。上述集成的模块既可以采用硬件的形式实现，也可以采用软件功能模块的形式实现。所述集成的模块如果以软件功能模块的形式实现并作为独立的产品销售或使用时，也可以存储在一个计算机可读取存储介质中。

上述提到的存储介质可以是只读存储器，磁盘或光盘等。

在本说明书的描述中，参考术语“一个实施例”、“一些实施例”、“示例”、“具体示例”、或“一些示例”等的描述意指结合该实施例或示例描述的具体特征、结构、材料或者特点包含于本申请的至少一个实施例或示例中。在本说明书中，对上述术语的示意性表述不一定指的是相同的实施例或示例。而且，描述的具体特征、结构、材料或者特点可以在任何的一个或多个实施例或示例中以合适的方式结合。

尽管上面已经示出和描述了本申请的实施例，可以理解的是，上述实施例是示例性的，不能理解为对本申请的限制，本领域的普通技术人员在本申请的范围内可以对上述实施例进行变化、修改、替换和变型。