数据处理方法、装置、设备、介质及程序产品与流程

本公开涉及互联网领域，特别是涉及一种数据处理方法、装置、设备、介质及程序产品。

背景技术：

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、可选的，所述第一确定单元具体用于：

58、如果所述对象信息中的触发逻辑流标识指示的触发逻辑流是动作启动的触发逻辑流，将所述内置存储空间存储的所述对象标识的对象状态设置为等待动作发生；

59、如果所述对象信息中的触发逻辑流标识指示的触发逻辑流不是动作启动的触发逻辑流，则从所述触发逻辑流中获取开始节点的下一节点，并为所述待触发对象跳转到所述下一节点。

60、可选的，所述第一生成单元具体用于：

61、获取所述节点的性质；

62、生成所述节点的性质相应的执行请求；

63、可选的，所述第一输出单元具体用于：

64、将所述执行请求按照所述节点的性质，放入所述节点性质对应的缓冲池中；

65、在所述缓冲池中，按照所述节点的标识将所述执行请求分区；

66、当判定满足预定条件时，将一个所述执行请求分区中的所述执行请求打成请求包，发送到所述节点对应的执行单元。

67、可选的，所述第一输出单元具体用于：

68、判定一个所述执行请求分区中的所述执行请求数目是否达到预定阈值；

69、当达到所述预定阈值时，判定满足预定条件；

70、如果未达到所述预定阈值，但当前时间与该执行请求分区中上一次打成请求包的时间的间隔大于预定时长，判定满足预定条件。

71、可选的，所述第一获取单元具体用于：

72、显示节点工具和连接关系工具；

73、响应于选择所述节点工具，显示用于生成所述节点的参数输入框；

74、利用所述参数输入框中输入的参数，生成所述节点；

75、响应于选择所述连接关系工具，生成所述节点之间的连接关系；

76、利用生成的所述节点和生成的所述连接关系，得到所述触发逻辑流。

77、可选的，所述第一获取单元具体用于：

78、显示所述触发逻辑流和删除工具；

79、响应于对所述删除工具的激活，接收对所述触发逻辑流中待删除节点的选择；

80、将选择的所述待删除节点、和该待删除节点与相邻节点的连接关系从所述触发逻辑流中删除。

81、根据本公开的一方面，提供了一种电子设备，包括存储器和处理器，所述存储器存储有计算机程序，所述处理器执行所述计算机程序时实现如上所述的针对对象的数据处理方法。

82、根据本公开的一方面，提供了一种计算机可读存储介质，所述存储介质存储有计算机程序，所述计算机程序被处理器执行时实现如上所述的针对对象的数据处理方法。

83、根据本公开的一方面，提供了一种计算机程序产品，该计算机程序产品包括计算机程序，所述计算机程序被计算机设备的处理器读取并执行，使得该计算机设备执行如上所述的针对对象的数据处理方法。

84、本公开实施例利用处理平台框架机制自带的内置存储空间，来存储待触发对象在触发逻辑流中流转时的状态，而不用读写外部数据库。同时，本公开实施例不需要设置内部的待执行队列。当结合内置存储空间中存储的待触发对象状态、节点性质和待触发对象的实时动作，确定出将跳转到触发逻辑流中的下一节点时，直接输出相应执行请求，由执行请求相应的执行单元执行。这样，可以使待触发对象在触发逻辑流的各节点间连续地流转，无需排队等待。通过上述过程，提高了触发逻辑流的自动触发中的数据处理效率和可靠性，降低了处理负荷。

85、本公开的其他特征和优点将在随后的说明书中阐述，并且，部分地从说明书中变得显而易见，或者通过实施本公开而了解。本公开的目的和其他优点可通过在说明书、权利要求书以及附图中所特别指出的结构来实现和获得。

技术特征：

1.一种针对对象的数据处理方法，用于处理平台框架，其特征在于，所述数据处理方法包括：

2.根据权利要求1所述的数据处理方法，其特征在于，所述根据所述节点的性质、所述待触发对象的实时动作、和所述内置存储空间存储的所述待触发对象的状态，确定为所述待触发对象跳转到所述触发逻辑流的下一节点，直到执行完所述触发逻辑流，包括：

3.根据权利要求2所述的数据处理方法，其特征在于，所述触发逻辑流以结构描述文件存储，所述结构描述文件包含各个所述节点的名称和下一节点标识；

4.根据权利要求1所述的数据处理方法，其特征在于，在获取触发逻辑流和待触发对象之后，所述数据处理方法还包括：获取跳转判定辅助指令；

5.根据权利要求4所述的数据处理方法，其特征在于，所述如果所述节点的性质是动作条件判断类节点，所述待触发对象的状态指示等待动作发生，且所述跳转判定辅助指令包含与所述动作条件判断类节点对应的实时动作，则从所述触发逻辑流中获取所述下一节点，并为所述待触发对象跳转到所述下一节点，包括：

6.根据权利要求4所述的数据处理方法，其特征在于，所述内置存储空间中还存储有所述触发逻辑流中的所述动作条件判断类节点的第一过期时间；

7.根据权利要求4所述的数据处理方法，其特征在于，所述内置存储空间中还存储有所述触发逻辑流中的等待节点的第二过期时间；

8.根据权利要求4所述的数据处理方法，其特征在于，所述获取跳转判定辅助指令，包括：

9.根据权利要求8所述的数据处理方法，其特征在于，所述获取对象的实时动作信息，包括：

10.根据权利要求9所述的数据处理方法，其特征在于，所述将所述实时动作、所述对象标识、与所述触发逻辑流的标识整合成所述实时动作信息，包括：

11.根据权利要求8所述的数据处理方法，其特征在于，所述获取查询结果信息，包括：

12.根据权利要求8所述的数据处理方法，其特征在于，所述获取加入触发逻辑流的对象信息，包括：

13.根据权利要求12所述的数据处理方法，其特征在于，所述根据所述节点的性质、所述待触发对象的实时动作、和所述内置存储空间存储的所述待触发对象的状态，确定为所述待触发对象跳转到所述触发逻辑流的下一节点，还包括：

14.根据权利要求1所述的数据处理方法，其特征在于，所述生成所述节点相应的执行请求，包括：获取所述节点的性质；生成所述节点的性质相应的执行请求；

15.根据权利要求14所述的数据处理方法，其特征在于，所述判定满足预定条件，包括：

16.根据权利要求1所述的数据处理方法，其特征在于，所述获取触发逻辑流，包括：

17.一种针对对象的数据处理装置，用于处理平台框架，其特征在于，包括：

18.一种电子设备，包括存储器和处理器，所述存储器存储有计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至16任意一项所述的针对对象的数据处理方法。

19.一种计算机可读存储介质，所述存储介质存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至16任意一项所述的针对对象的数据处理方法。

20.一种计算机程序产品，该计算机程序产品包括计算机程序，所述计算机程序被计算机设备的处理器读取并执行，使得该计算机设备执行权利要求1至16任意一项所述的针对对象的数据处理方法。

技术总结
本公开提供了一种针对对象的数据处理方法、装置、设备、介质及程序产品。该数据处理方法包括：获取触发逻辑流和待触发对象；当针对待触发对象执行触发逻辑流的节点时，利用处理平台框架的内置存储空间存储待触发对象的状态，并生成该节点相应的执行请求；根据该节点的性质、待触发对象的实时动作、和存储的待触发对象的状态，确定为待触发对象跳转到该触发逻辑流的下一节点，直到执行完触发逻辑流；输出执行该触发逻辑流的各节点生成的执行请求，以便执行单元执行，从而向待触发对象发送数据触发结果。本公开用于互联网、大数据、信息处理等领域。本公开实施例提高了执行触发逻辑流的自动触发时的数据处理效率和可靠性，降低了处理负荷。

技术研发人员：徐宁,赵伟栋,邓宇乐,徐敏,郭超,钱波
受保护的技术使用者：腾讯科技（深圳）有限公司
技术研发日：
技术公布日：2024/9/23