埋点数据上报方法、装置、计算机设备及可读存储介质与流程

未命名 08-20 阅读:171 评论:0


1.本技术涉及数据分析技术领域,尤其涉及一种埋点数据上报方法、装置、计算机设备及可读存储介质。


背景技术:

2.为了提升用户的粘性,通常需要向用户进行推送数据,从而提高与用户的交互。
3.而每个用户看到的运营数据因圈客规则会有差异,每个运营数据都是需要曝光和点击埋点以方便统计数据,给运营投放数据提供数据支撑,页面需要同时加载大量的用户访问量,相应的也存在大量的埋点曝光量。目前埋点数据上报通常采用节流方式,而一般的节流方式是指同一位置触发调用节流是不管同一时间内触发多少次,只会每间隔预设时间才会触发一次上报事件,在存在埋点位置同时触发时,采用这种节流方式会存在漏报埋点数据的问题。


技术实现要素:

4.本技术的主要目的在于提供一种埋点数据上报方法、装置、计算机设备及可读存储介质,旨在通过预先设置埋点数据的运行节点,从而使得列队按照设置的顺序进行执行埋点数据,便于记录执行的顺序以及减少执行埋点数据上报的次数,在上报数据的过程中,实现基于列队的执行顺序上报执行数据,无需实时进行上报,在节流的同时,避免漏报数据,利于业务人员开展运营工作。
5.第一方面,本技术提供了一种埋点数据上报方法,所述方法包括:
6.创建埋点数据存储列队;
7.在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;
8.根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;
9.在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;
10.根据执行顺序上报执行所述第一埋点数据的事项。
11.第二方面,本技术还提供了一种埋点数据上报装置,所述装置包括:
12.创建模块,用于创建埋点数据存储列队;
13.设置模块,用于在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;
14.存储模块,用于根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;
15.执行模块,用于在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;
16.上报模块,用于根据执行顺序上报执行所述第一埋点数据的事项。
17.第三方面,本技术还提供了一种计算机设备,所述计算机设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机程序,其中所述计算机程序
被所述处理器执行时,实现如上述的埋点数据上报方法的步骤。
18.第四方面,本技术还提供了一种计算机可读存储介质,所述计算机可读存储介质上存储有计算机程序,其中所述计算机程序被处理器执行时,实现如上述的埋点数据上报方法。
19.本技术公开了一种埋点数据上报方法、装置、计算机设备及可读存储介质,该埋点数据上报方法,首先创建埋点数据存储列队;在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据,从而根据运行节点的顺序执行第一埋点数据,通过预先设置埋点数据的运行节点,从而只在特定的时间点进行执行,不需要实时进行执行,减少了执行次数,延缓并发调用的压力,从而实现节流;另一方面,根据执行顺序上报执行所述第一埋点数据的事项,在上报数据的过程中,实现基于列队的执行顺序上报执行数据,由于每个埋点上报的时间戳都是唯一的,在一定程度上缓解了后台接口的调用压力,同时即使同一时间有多个埋点数据进行执行,也可以保证业务上每个埋点都能正常入库,无需实时进行上报,在节流的同时,避免漏报数据,利于业务人员开展运营工作。
20.应当理解的是,以上的一般描述和后文的细节描述仅是示例性和解释性的,并不能限制本技术。
附图说明
21.为了更清楚地说明本技术实施例技术方案,下面将对实施例描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图是本技术的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。
22.图1为本技术埋点数据上报方法一实施例的流程示意图;
23.图2为本技术埋点数据上报方法另一实施例的流程示意图;
24.图3为本技术埋点数据上报方法一实施例涉及的第一埋点数据的添加的示例图;
25.图4为本技术一实施例提供的一种埋点数据上报装置的示意性框图;
26.图5为本技术一实施例涉及的计算机设备的结构示意框图。
27.本技术目的的实现、功能特点及优点将结合实施例,参照附图做进一步说明。
具体实施方式
28.下面将结合本技术实施例中的附图,对本技术实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本技术一部分实施例,而不是全部的实施例。基于本技术中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本技术保护的范围。
29.附图中所示的流程图仅是示例说明,不是必须包括所有的内容和操作/步骤,也不是必须按所描述的顺序执行。例如,有的操作/步骤还可以分解、组合或部分合并,因此实际执行的顺序有可能根据实际情况改变。
30.应当理解,在此本技术说明书中所使用的术语仅仅是出于描述特定实施例的目的而并不意在限制本技术。如在本技术说明书和所附权利要求书中所使用的那样,除非上下
文清楚地指明其它情况,否则单数形式的“一”、“一个”及“该”意在包括复数形式。
31.还应当进理解,在本技术说明书和所附权利要求书中使用的术语“和/或”是指相关联列出的项中的一个或多个的任何组合以及所有可能组合,并且包括这些组合。
32.本技术的实施例提供了一种埋点数据上报方法、装置、计算机设备及可读存储介质。该埋点数据上报方法主要应用于数据上报设备,该数据上报设备可以是服务器等具有数据处理功能的终端设备。
33.其中,服务器可以是独立的服务器,也可以是提供云服务、云数据库、云计算、云函数、云存储、网络服务、云通信、中间件服务、域名服务、安全服务、内容分发网络(content delivery network,cdn)、以及大数据和数据分析平台等基础云计算服务的云服务器。
34.下面结合附图,对本技术的一些实施方式作详细说明。在不冲突的情况下,下述的实施例及实施例中的特征可以相互组合。
35.本技术提供一种埋点数据上报方法、装置、计算机设备及可读存储介质,该埋点数据上报方法旨在实现基于列队的执行顺序上报执行数据,从而避免漏报数据,利于业务人员开展运营工作。
36.请参照图1,图1为本技术的实施例提供的一种埋点数据上报方法的流程示意图。
37.如图1所示,该埋点数据上报方法包括步骤s101至步骤s105。
38.步骤s101、创建埋点数据存储列队。
39.在本实施例中,需要上报的埋点数据具体通过创建的列队进行存储,在创建列队时,需指定容量,即设置队列的长度,具体的,列队的长度可根据数据的大小进行设置,在此不做限制。埋点数据是指用户的行为数据,具体是通过对产品进行埋点,基于埋点分析对用户点击埋点的行为数据进行采集得到的,或者通过用户对应的终端直接发送得到的。
40.步骤s102、在接收到第一埋点数据时,设置所述第一埋点数据的运行节点。
41.在接收到第一埋点数据,即需要执行的数据的情况下,根据数据的属性,设置第一埋点数据的运行节点,其中,执行可理解为对埋点数据的上报,或者对埋点数据的推送等,以执行为上报为例,即定义一个开关running(管理)和timer(a时间节点)用来控制每一个上报数据是否立即执行上报。比如,假设第一埋点数据的属性为需要马上执行上报,则将运行节点设置为马上执行上报;假设第一埋点数据的属性为一小时后执行上报,则将第一埋点数据的运行节点设置为一小时后进行执行上报。
42.步骤s103、根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队。
43.在设置好运行节点之后,即可根据运行节点,将第一埋点数据存储至埋点数据存储列队中。比如,在第一埋点数据的运行节点为马上执行上报或马上执行推送的情况下,则将第一埋点数据存储至埋点数据存储队列的前端,从而实现优先对第一埋点数据进行执行上报或推送。
44.在存储第一埋点数据的过程中,可以先识别埋点数据存储队列是否已满,在埋点数据存储队列未满时,将第一埋点数据存储至至埋点数据存储队列,在埋点数据存储队列已满时,从埋点数据存储队列中移出最先进入该埋点数据存储队列的数据,再将第一埋点数据存储至埋点数据存储队列。
45.步骤s104、在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行
所述第一埋点数据。
46.在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据。其中,运行条件可包括时间节点、位置节点等。
47.在运行条件包括时间节点的情况下,步骤s104具体为:检测所述埋点数据存储列队的运行节点;将所述运行节点对应的时间点与当前时间点进行对比;在所述运行节点对应的时间点与所述当前时间点的差值小于预设阈值的情况下,获取所述运行节点对应的第一埋点数据,作为所述埋点数据存储列队的出栈并进行执行。
48.检测埋点数据存储列队的运行节点,即各个第一埋点数据的运行节点所对应的时间点,并将运行节点对应的时间点与当前时间点进行对比;在运行节点对应的时间点与当前时间点的差值小于预设阈值的情况下,说明当前时间有需要执行上报的第一埋点数据,则获取运行节点对应的第一埋点数据,作为埋点数据存储列队的出栈并进行执行。
49.在运行条件包括位置节点的情况下,获取第一埋点数据在埋点数据存储列队中的位置,在第一埋点数据在埋点数据存储列队的首端的情况下,将第一埋点数据作为埋点数据存储列队的出栈并进行执行上报。
50.进一步地,为了执行程序的严谨性,以及为了降低程序的执行次数,在步骤104之前,还可以包括:判断所述埋点数据存储列队的数据长度是否大于0;在所述埋点数据存储列队大于0的情况下,检测当前运行条件是否符合所述运行节点对应的运行条件。
51.具体地,先判断埋点数据存储列队的数据长度是否大于0;在埋点数据存储列队大于0的情况下,才检测当前运行条件是否符合运行节点对应的运行条件,从而减少检测的次数,降低程序的执行次数。
52.步骤s105、根据执行顺序上报执行所述第一埋点数据的事项。
53.在采集得到第一埋点数据之后,可以根据第一埋点数据的重要性,将运行节点设置为,在采集埋点数据之后马上进行上报,或者先记录数据的执行顺序,在记录的值到达一定阈值的情况下,再根据记录的顺序进行上报。由于执行数据是具有顺序的,因此,不管是在采集之后马上进行上报,还是先记录再进行上报,都可以实现按照数据的执行顺序进行数据上报,从而实现每个埋点上报的时间戳都是唯一的,在一定程度上缓解了后台接口的调用压力,保证业务上每个埋点都能正常入库,不遗漏数据。
54.具体地,在执行为推送的情况下,步骤s105具体为:在检测到运行条件符合所述运行节点对应的运行条件的情况下,将所述第一埋点数据进行推送。
55.在本实施例中,对第一埋点数据的执行可以包括对第一埋点数据的推送,此时,在检测到运行条件符合所述运行节点对应的运行条件的情况下,将第一埋点数据进行推送。
56.具体的,第一埋点数据可以为运营产品对应的数据,或者对用户行为采集得到的数据,具体可以通过用户授权之后,由用户对应的数据来源终端实时传输的数据,或通过用户授权之后,对用户的浏览、点击行为等进行采集得到的数据,即获取到的第一埋点数据,获取得到数据来源终端实时传输的第一埋点数据之后,添加至所述埋点数据存储列队,再通过埋点数据存储列队进行推送,从而通过埋点数据存储列队推送给相关的监控订阅方,具体的,订阅方的推送目标地址可以在订阅方订阅时获取,并通过在发出第一埋点数据时将地址信息附带在第一埋点数据中,或者将订阅方的地址信息与数据来源终端进行对应,建立订阅方与数据来源终端之间的对应关系或者地址链接,订阅方的目标地址信息可以携
带在第一埋点数据中,通过数据存储列队获取该地址信息并进行推送,也可以在对应关系中以获取地址信息,然后通过将地址信息附着在第一埋点数据上,通过数据存储列队获取该地址信息并进行推送,具体可以根据实际情况进行设置,本发明在此不做具体的限定。
57.进一步地,所述步骤105之后还可以包括:获取所述第一埋点数据的数据来源终端的识别信息;根据所述识别信息将所述第一埋点数据存储至所述数据存储列队中对应的推送子列队中。
58.进一步地,为了保证同一终端的数据分配到同一数据存储列队中,可将数据存储列队划分为多个推送子列队,并将第一埋点数据放置到对应识别信息,即终端标识的推送子列队中,主要用于将数据来源终端相同的第一埋点数据放置到相同的推送子列队,也就是说将同一个数据来源终端传输来的第一埋点数据都分配到同一个推送子列队中被处理,避免推送乱序。
59.在上报数据的执行情况之后,可以进一步对数据存储列队进行补充,具体参照图2,步骤105之后,还可以包括步骤s106至步骤s107。
60.步骤s106、获取第二埋点数据;
61.步骤s107、将所述第二埋点数据插入至所述数据存储列队后端。
62.具体地,参考图3,先定义一个add data(添加数据)来执行数据添加,然后获取第二埋点数据,并将第二埋点数据插入至埋点数据存储列队后端,即所述埋点数据存储列队的队尾。再定义一个add data(添加数据)来执行数据添加在将第二埋点数据插入至所述埋点数据存储列队后端之前,可进一步判断所述埋点数据存储列队的状态,在埋点数据存储列队的状态为未满的情况下,再将第二埋点数据进行记录,存储至埋点数据存储列队的尾端。在埋点数据存储列队的状态为已满的情况下,先将第二埋点数据进行记录,在埋点数据存储队列的队尾至队首方向上存储第一个空闲位置的情况下,再将所述第二埋点数据进行存储。
63.通过上述步骤,能够保证埋点数据存储列队中数据记录至队尾,保证埋点数据存储列队始终沿着从队首至队尾的执行顺序。
64.具体地,在埋点数据存储列队的状态为已满的情况下,先在符合运行条件的情况下,将在埋点数据存储列队的队首的第一埋点数据移出进行执行,并将埋点数据存储列队当前的第一埋点数据顺次向已移出的第一埋点数据在埋点数据存储列队中的位置移动,在完成移动后,将获取到的第二埋点数据记录至埋点数据存储列队中的空闲位置。这样,也能够保证埋点数据存储列队中最先进入的数据请求记录至队首,保证埋点数据存储列队始终沿着从队尾至队首的方向记录数据。
65.为更好理解上述实施例,举例应用场景如下:
66.首先在本实施例中,创建用于存储第一埋点数据的埋点数据存储列队,在创建列队时,需指定容量,即设置队列的长度,列队的长度可根据数据的大小进行设置。在接收到第一埋点数据,即需要执行的数据的情况下,根据数据的属性,设置第一埋点数据的运行节点,即定义一个开关running(管理)和timer(a时间节点)用来控制每一个上报数据是否立即执行。在设置好运行节点之后,即可根据运行节点,将第一埋点数据存储至埋点数据存储列队中。比如,在第一埋点数据的运行节点为马上执行的情况下,则将第一埋点数据存储至埋点数据存储队列的前端,从而实现优先对第一埋点数据进行执行。在检测到运行条件符
合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据。其中,运行条件可包括时间节点、位置节点等。在执行第一埋点数据之后,可以将执行条件设置为,在执行数据之后马上进行上报,或者先记录数据的执行顺序,在记录的值到达一定阈值的情况下,再根据记录的顺序进行上报。由于通过预先设置埋点数据的运行节点,从而只在特定的时间点进行执行,不需要实时进行执行,减少了执行次数,延缓并发调用的压力,从而实现节流;另一方面,根据执行顺序上报执行所述第一埋点数据的事项,在上报数据的过程中,实现基于列队的执行顺序上报执行数据,由于每个埋点上报的时间戳都是唯一的,在一定程度上缓解了后台接口的调用压力,同时即使同一时间有多个埋点数据进行执行,也可以保证业务上每个埋点都能正常入库,无需实时进行上报,在节流的同时,避免漏报数据,利于业务人员开展运营工作。
67.上述实施例提供的埋点数据上报方法,首先创建埋点数据存储列队;在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据,通过预先设置埋点数据的运行节点,从而只在特定的时间点进行执行,不需要实时进行执行,减少了执行次数,延缓并发调用的压力,从而实现节流;另一方面,根据执行顺序上报执行所述第一埋点数据的事项,在上报数据的过程中,实现基于列队的执行顺序上报执行数据,由于每个埋点上报的时间戳都是唯一的,在一定程度上缓解了后台接口的调用压力,同时即使同一时间有多个埋点数据进行执行,也可以保证业务上每个埋点都能正常入库,无需实时进行上报,在节流的同时,避免漏报数据,利于业务人员开展运营工作。
68.请参照图4,图4为本技术实施例提供的一种埋点数据上报装置的示意性框图。
69.如图4所示,该装置400,包括:创建模块401、设置模块402、存储模块403、执行模块405和上报406。
70.创建模块401,用于创建埋点数据存储列队;
71.设置模块402,用于在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;
72.存储模块403,用于根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;
73.执行模块404,用于在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;
74.上报模块405,用于根据执行顺序上报执行所述第一埋点数据的事项。
75.需要说明的是,所属领域的技术人员可以清楚地了解到,为了描述的方便和简洁,上述描述的装置和各模块及单元的具体工作过程,可以参考前述埋点数据上报方法实施例中的对应过程,在此不再赘述。
76.上述实施例提供的装置可以实现为一种计算机程序的形式,该计算机程序可以在如图5所示的计算机设备上运行。
77.请参阅图5,图5为本技术实施例提供的一种计算机设备的结构示意性框图。该计算机设备可以是个人计算机(personal computer,pc)、服务器等具有数据处理功能的设备。
78.如图5所示,该计算机设备包括通过系统总线连接的处理器、存储器和网络接口,其中,存储器可以包括非易失性存储介质和内存储器。
79.非易失性存储介质可存储操作系统和计算机程序。该计算机程序包括程序指令,该程序指令被执行时,可使得处理器执行任意一种埋点数据上报方法。
80.处理器用于提供计算和控制能力,支撑整个计算机设备的运行。
81.内存储器为非易失性存储介质中的计算机程序的运行提供环境,该计算机程序被处理器执行时,可使得处理器执行任意一种埋点数据上报方法。
82.该网络接口用于进行网络通信,如发送分配的任务等。本领域技术人员可以理解,图5中示出的结构,仅仅是与本技术方案相关的部分结构的框图,并不构成对本技术方案所应用于其上的计算机设备的限定,具体的计算机设备可以包括比图中所示更多或更少的部件,或者组合某些部件,或者具有不同的部件布置。
83.应当理解的是,处理器可以是中央处理单元(central processing unit,cpu),该处理器还可以是其他通用处理器、数字信号处理器(digital signal processor,dsp)、专用集成电路(application specific integrated circuit,asic)、现场可编程门阵列(field-programmable gate array,fpga)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。其中,通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。
84.其中,在一个实施例中,所述处理器用于运行存储在存储器中的计算机程序,以实现如下步骤:
85.创建埋点数据存储列队;
86.在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;
87.根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;
88.在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;
89.根据执行顺序上报执行所述第一埋点数据的事项。
90.在一些实施例中,所述处理器实现所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据时,用于实现:
91.检测所述埋点数据存储列队的运行节点;
92.将所述运行节点对应的时间点与当前时间点进行对比;
93.在所述运行节点对应的时间点与所述当前时间点的差值小于预设阈值的情况下,获取所述运行节点对应的第一埋点数据,作为所述埋点数据存储列队的出栈并进行执行。
94.在一些实施例中,所述处理器实现所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据之前,用于实现:
95.判断所述埋点数据存储列队的数据长度是否大于0;
96.在所述埋点数据存储列队大于0的情况下,检测当前运行条件是否符合所述运行节点对应的运行条件。
97.在一些实施例中,所述处理器实现所述根据执行顺序上报执行所述第一埋点数据的事项之后,用于实现:
98.获取第二埋点数据;
99.将所述第二埋点数据插入至所述埋点数据存储列队后端。
100.在一些实施例中,所述处理器实现所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据时,用于实现:
101.在检测到运行条件符合所述运行节点对应的运行条件的情况下,将所述第一埋点数据进行推送。
102.在一些实施例中,所述处理器实现所述根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队之后,用于实现:
103.获取所述第一埋点数据的数据来源终端的识别信息;
104.根据所述识别信息将所述第一埋点数据存储至所述埋点数据存储列队中对应的推送子列队中。
105.本技术实施例还提供一种计算机可读存储介质,所述计算机可读存储介质上存储有计算机程序,所述计算机程序中包括程序指令,所述程序指令被执行时所实现的方法可参照本技术埋点数据上报方法的各个实施例。
106.其中,所述计算机可读存储介质可以是前述实施例所述的计算机设备的内部存储单元,例如所述计算机设备的硬盘或内存。所述计算机可读存储介质也可以是所述计算机设备的外部存储设备,例如所述计算机设备上配备的插接式硬盘,智能存储卡(smart media card,smc),安全数字(secure digital,sd)卡,闪存卡(flash card)等。
107.进一步地,所述计算机可读存储介质可主要包括存储程序区和存储数据区,其中,存储程序区可存储操作系统、至少一个功能所需的应用程序等;存储数据区可存储根据区块链节点的使用所创建的数据等。
108.本发明所指区块链是分布式数据存储、点对点传输、共识机制、加密算法等计算机技术的新型应用模式。区块链(blockchain),本质上是一个去中心化的数据库,是一串使用密码学方法相关联产生的数据块,每一个数据块中包含了一批次网络交易的信息,用于验证其信息的有效性(防伪)和生成下一个区块。区块链可以包括区块链底层平台、平台产品服务层以及应用服务层等。
109.需要说明的是,在本文中,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者系统不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者系统所固有的要素。在没有更多限制的情况下,由语句“包括一个
……”
限定的要素,并不排除在包括该要素的过程、方法、物品或者系统中还存在另外的相同要素。
110.上述本技术实施例序号仅仅为了描述,不代表实施例的优劣。以上所述,仅为本技术的具体实施方式,但本技术的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本技术揭露的技术范围内,可轻易想到各种等效的修改或替换,这些修改或替换都应涵盖在本技术的保护范围之内。因此,本技术的保护范围应以权利要求的保护范围为准。

技术特征:
1.一种埋点埋点数据上报方法,其特征在于,所述方法包括以下步骤:创建埋点数据存储列队;在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;根据执行顺序上报执行所述第一埋点数据的事项。2.根据权利要求1所述的埋点数据上报方法,其特征在于,所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据,包括:检测所述埋点数据存储列队的运行节点;将所述运行节点对应的时间点与当前时间点进行对比;在所述运行节点对应的时间点与所述当前时间点的差值小于预设阈值的情况下,获取所述运行节点对应的第一埋点数据,作为所述数据存储列队的出栈并进行执行。3.根据权利要求1所述的埋点数据上报方法,其特征在于,所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据之前,还包括:判断所述埋点数据存储列队的数据长度是否大于0;在所述埋点数据存储列队大于0的情况下,检测当前运行条件是否符合所述运行节点对应的运行条件。4.根据权利要求1所述的埋点数据上报方法,其特征在于,所述根据执行顺序上报执行所述第一埋点数据的事项之后,还包括:获取第二埋点数据;将所述第二埋点数据插入至所述埋点数据存储列队后端。5.根据权利要求1所述的埋点数据上报方法,其特征在于,所述在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据,包括:在检测到运行条件符合所述运行节点对应的运行条件的情况下,将所述第一埋点数据进行推送。6.根据权利要求1所述的埋点数据上报方法,其特征在于,所述根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队之后,还包括:获取所述第一埋点数据的埋点数据来源终端的识别信息;根据所述识别信息将所述第一埋点数据存储至所述埋点数据存储列队中对应的推送子列队中。7.一种埋点数据上报装置,其特征在于,所述埋点数据上报装置包括:创建模块,用于创建埋点数据存储列队;设置模块,用于在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;存储模块,用于根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;执行模块,用于在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;上报模块,用于根据执行顺序上报执行所述第一埋点数据的事项。
8.根据权利要求7所述的埋点数据上报装置,其特征在于,所述执行模块包括:检测子模块,用于检测所述埋点数据存储列队的运行节点;对比子模块,用于将所述运行节点对应的时间点与当前时间点进行对比;获取子模块,用于在所述运行节点对应的时间点与所述当前时间点的差值小于预设阈值的情况下,获取所述运行节点对应的第一埋点数据,作为所述埋点数据存储列队的出栈并进行执行。9.一种计算机设备,其特征在于,所述计算机设备包括处理器、存储器、以及存储在所述存储器上并可被所述处理器执行的计算机程序,其中所述计算机程序被所述处理器执行时,实现如权利要求1至6中任一项所述的埋点数据上报方法的步骤。10.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质上存储有计算机程序,其中所述计算机程序被处理器执行时,实现如权利要求1至6中任一项所述的埋点数据上报方法的步骤。

技术总结
本申请属于数据分析技术领域,提供了一种埋点数据上报方法、装置、计算机设备及可读存储介质,包括:创建埋点数据存储列队;在接收到第一埋点数据时,设置所述第一埋点数据的运行节点;根据所述运行节点,将所述第一埋点数据存储至所述埋点数据存储列队;在检测到运行条件符合所述运行节点对应的运行条件的情况下,执行所述第一埋点数据;根据执行顺序上报执行所述第一埋点数据的事项。本申请能够实现列队按照设置的顺序进行执行埋点数据,根据执行顺序上报执行第一埋点数据的事项,便于记录执行的顺序以及减少执行埋点数据上报的次数,在上报数据的过程中,实现基于列队的执行顺序上报执行数据,无需实时进行上报,在节流的同时,避免漏报数据。免漏报数据。免漏报数据。


技术研发人员:李双
受保护的技术使用者:平安科技(深圳)有限公司
技术研发日:2023.04.06
技术公布日:2023/8/14
版权声明

本文仅代表作者观点,不代表航空之家立场。
本文系作者授权航家号发表,未经原创作者书面授权,任何单位或个人不得引用、复制、转载、摘编、链接或以其他任何方式复制发表。任何单位或个人在获得书面授权使用航空之家内容时,须注明作者及来源 “航空之家”。如非法使用航空之家的部分或全部内容的,航空之家将依法追究其法律责任。(航空之家官方QQ:2926969996)

飞行汽车 https://www.autovtol.com/

分享:

扫一扫在手机阅读、分享本文

相关推荐