多场景流式数据处理方法、系统、网络设备和存储介质

摘要

本申请提供一种多场景流式数据处理方法、系统、网络设备和存储介质，属于计算机技术领域。本申请实施例提供的多场景流式数据处理方法，包括获取目标应用的原始流式数据；根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；将获取到的成对的流式数据存储至数据库；通过上述方法实现了对目标应用在多场景下的流式数据获取，并按各个场景的数据处理规则获取承兑的流式数据后，将所有成对的流式数据存入同一数据库中，实现了支持多场景流式数据的处理。

权利要求

1.一种多场景流式数据处理方法，其特征在于，所述方法包括：

获取目标应用的原始流式数据；

根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；场景类型是目标应用下的各业务功能；

获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；所述数据处理规则包括以下至少之一：根据目标场景类型下目标用户的操作行为，确定成对的流式数据；根据目标场景类型下目标用户的操作行为对应的时间，确定成对的流式数据；其中，每一种操作行为包括开始信息和结束信息，同一种操作行为的开始信息和结束信息能够组成一对流式数据；所述成对的流式数据是根据不同业务场景下用户的操作行为来确定的；

根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；

将获取到的成对的流式数据存储至数据库。

2.根据权利要求1所述的多场景流式数据处理方法，其特征在于，所述方法还包括：基于所述数据库中存储的数据对应的场景类型，搭建数据看板，所述数据看板支持所述数据库中所有场景类型的数据的展示；

根据用户发起的查询请求，在所述数据看板上展示对应所述查询请求的数据。

3.根据权利要求1所述的多场景流式数据处理方法，其特征在于，根据目标场景类型下目标用户的操作行为对应的时间，确定成对的流式数据包括：当目标用户在预设时间范围内重复出现同一操作行为的多个开始信息或多个结束信息时，以最先出现的开始信息或最先出现的结束信息为准；或者以最后出现的开始信息或最后出现的结束信息为准。

4.根据权利要求3所述的多场景流式数据处理方法，其特征在于，所述根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据包括：根据所述数据处理规则，并根据操作行为的开始信息和操作行为的结束信息匹配成对的流式数据，且按所述数据处理规则生成存储于所述数据库的成对的流式数据对应的实际存储数据。

5.根据权利要求4所述的多场景流式数据处理方法，其特征在于，所述数据处理规则还包括跨天数据规则：若目标成对的流式数据中的开始信息的时间与结束信息的时间跨天，将所述目标成对的流式数据拆分为两对流式数据进行保存；

其中，开始信息至跨天0时信息为一对流式数据，跨天0时信息与结束信息为一对流式数据。

6.根据权利要求1所述的多场景流式数据处理方法，其特征在于，所述场景类型包括每条成对的流式数据对应的用户操作场景，至少包括以下之一：语音信息输入、视频信息输入、人脸识别操作、指纹识别操作、支付操作。

7.一种多场景数据流式处理系统，其特征在于，所述系统包括：

原始数据获取模块，用于获取目标应用的原始流式数据；

流式数据提取模块，用于根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；场景类型是目标应用下的各业务功能；

多场景规则配置模块，用于获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；

流式数据处理模块，用于根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；所述数据处理规则包括以下至少之一：根据目标场景类型下目标用户的操作行为，确定成对的流式数据；根据目标场景类型下目标用户的操作行为对应的时间，确定成对的流式数据；其中，每一种操作行为包括开始信息和结束信息，同一种操作行为的开始信息和结束信息能够组成一对流式数据；所述成对的流式数据是根据不同业务场景下用户的操作行为来确定的；

数据存储模块，用于将获取到的成对的流式数据存储至数据库；

其中，所述对应的配置信息包括对应于所述场景类型的数据处理规则。

8.一种网络设备，其特征在于，包括：处理器、存储器及存储在所述存储器上并可在所述处理器上运行的程序，所述程序被所述处理器执行时实现如权利要求1至6中任一项所述的多场景流式数据处理方法的步骤。

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

说明书

多场景流式数据处理方法、系统、网络设备和存储介质

技术领域

[0001] 本申请涉及计算机技术领域，尤其涉及一种多场景流式数据处理方法、系统、网络设备和存储介质。

背景技术

[0002] 目前的社交产品都有各自业务的主要功能，例如语音功能、视频功能、游戏功能。为了完成产品的各功能，通常需要分别每个功能配置一个数据表用以存储数据。当需要分析各个功能产生的使用数据时，使用语音功能时的开麦时间，使用视频功能时的开麦及开摄时间等用户数据时，需要分别在各个数据表上搭建数据看板；当不同数据表对应的功能类似时，搭建数据看板的步骤基本一致，造成搭建过程中一定人力物力的浪费。

[0003] 在进行数据查询时，目前通常为不同功能分别搭建数据看板以供数据查看，且无法实现跨天数据的直接查询；如面对一定时间范围内的查询、跨天查询等特殊查询场景时；也就导致了无法查询过程繁琐、看板搭建过程冗余、无法适配多种场景也无法实现跨天数据场景等问题。

发明内容

[0004] 本申请提出了一种多场景流式数据处理方法、系统、网络设备和存储介质，以解决现有技术中数据处理时看板搭建繁琐、查询过程复杂以及不支持多场景处理查询等问题。

[0005] 为了解决上述技术问题，本申请是这样实现的：

[0006] 第一方面，本申请实施例提供了一种多场景流式数据处理方法，包括：

[0007] 获取目标应用的原始流式数据；

[0008] 根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；

[0009] 获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；

[0010] 根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；

[0011] 将获取到的成对的流式数据存储至数据库。

[0012] 第二方面，本申请实施例提供了一种多场景数据流式处理系统，包括：

[0013] 原始数据获取模块，用于获取目标应用的原始流式数据；

[0014] 流式数据提取模块，用于根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；

[0015] 多场景规则配置模块，用于获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；

[0016] 流式数据处理模块，用于根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；

[0017] 数据存储模块，用于将获取到的成对的流式数据存储至数据库。

[0018] 第三方面，本申请实施例提供了一种网络设备，包括：处理器、存储器及存储在所述存储器上并可在所述处理器上运行的程序，所述程序被所述处理器执行时实现上述第一方面的多场景流式数据处理方法的步骤。

[0019] 第四方面，本申请实施例提供了一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现上述第一方面的多场景流式数据处理方法的步骤。

[0020] 本申请实施例提供的技术方案带来的有益效果至少包括：

[0021] 本申请提供的多场景流式数据处理方法，包括获取目标应用的原始流式数据；根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；将获取到的成对的流式数据存储至数据库；通过上述方法实现了对目标应用在多场景下的流式数据获取，并按各个场景的数据处理规则获取承兑的流式数据后，将所有成对的流式数据存入同一数据库中，实现了支持多场景流式数据的处理。

附图说明

[0022] 通过阅读下文优选实施方式的详细描述，各种其他的优点和益处对于本领域普通技术人员将变得清楚明了。附图仅用于示出优选实施方式的目的，而并不认为是对本申请的限制。而且在整个附图中，用相同的参考符号表示相同的部件。在附图中：

[0023] 图1为本申请实施例提供的一种多场景流式数据处理方法流程图；

[0024] 图2为本申请实施例提供的一种流式数据跨天处理流程示意；

[0025] 图3为本申请实施例提供的一种用户的在语音输入下的操作对应的流式数据记录流程示意；

[0026] 图4为本申请实施例提供的一种多场景数据流式处理系统的结构示意图；

[0027] 图5为本申请实施例提供的另一种多场景数据流式处理系统的结构示意图；

[0028] 图6为本申请实施例提供的一种网络设备的结构示意图。

具体实施方式

[0029] 下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚地描述，显然，所描述的实施例是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员获得的所有其他实施例，都属于本申请保护的范围。

[0030] 本申请的说明书和权利要求书中的术语“第一”、“第二”等是用于区别类似的对象，而不用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便本申请的实施例能够以除了在这里图示或描述的那些以外的顺序实施，且“第一”、“第二”等所区分的对象通常为一类，并不限定对象的个数，例如第一对象可以是一个，也可以是多个。此外，说明书以及权利要求中“和/或”表示所连接对象的至少其中之一，字符“/”，一般表示前后关联对象是一种“或”的关系。

[0031] 下面结合附图，通过具体的实施例及其应用场景对本申请实施例提供的多场景流式数据处理方法、系统、网络设备和存储介质等进行详细地说明。

[0032] 请参考图1，图1示出了本申请实施例提供的一种多场景流式数据处理方法流程图，所述方法包括：

[0033] 步骤11，获取目标应用的原始流式数据。

[0034] 具体的，可通过binlog日志来获取流式数据，如开启binlog日志，获取原始流式数据并发送至特定的消息队列；示例性的，可以通过Canal工具来获取binlog日志中的原始流式数据；可以通过kafka消息队列工具来接收Canal获取的binlog日志。通过步骤11能够获取到目标应用的原始流式数据，并发送至特定消息队列处理工具，有助于步骤12中根据场景类型来获取特定场景下可能会生成的流式数据。

[0035] 步骤12，根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据。

[0036] 具体的，接收kafka队列中的binlog日志，根据场景类型获取流式数据；这里的场景类型可是目标应用下的各业务功能；如，用户使用视频功能时的场景，在此场景类型下用户可以进行开启关闭摄像头及麦克风操作，此时流式数据则为依次出现的开启摄像头、关闭摄像头，以及依次出现的开启麦克风、关闭麦克风操作对应的数据。

[0037] 具体的，目标应用也可以具备其他业务功能，如音频功能、指纹识别功能、人脸识别功能、支付功能，不同的业务功能（场景类型）下用户能够执行不同的操作类型，每个场景类型下都会因为用户操作类型的不同而生成对应的流式数据。通过步骤12能够根据不同的业务场景类型，提取对应的流式数据，原始流式数据的信息中通常会包含每一条数据产生的业务场景，以及具体的操作类型，通过这种方式能够精准的根据场景类型提取出需要处理的目标场景下目标用户对应的流式数据。

[0038] 步骤13，获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据。

[0039] 具体的，根据业务场景配置对应的数据处理规则，每个场景都对应有各自的流式数据的处理规则，这些数据处理规则能够应用于对流式数据的提取、删减、以及确定成对的流式数据。通过设置业务场景对应的数据处理规则，能够实现统计特定场景下用户的特定操作行为的持续时间，查询每日每周每月的用户操作次数，分析用户行为。特定场景下用户的特定操作行为的持续时间，如视频功能的开启摄像头时间、开启麦克风时间，支付功能的完成支付所需时间。以上的操作行为的持续时间中，一定有操作行为的开始时间和结束时间。而开始时间和结束时间可能存在跨天、连续的开始时间或连续的结束时间，因此需要匹配特定场景类型对应的数据处理规则进行处理，从而获取特定场景对应的成对的流式数据。

[0040] 步骤14，根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据。

[0041] 具体的，成对的流式数据是根据不同业务场景下用户的操作行为来确定的，如用户在使用不同业务功能时，会出现的开始操作和结束操作，如视频输入功能以后开始录制、结束录制；指纹识别功能中会出现请输入指纹，输入完成，开始识别，识别通过，重新识别等操作；为这些不同的业务场景，设置各自对应的数据处理规则，能够有效的提取出原始流式数据中，目标场景下目标用户执行操作生成的流式数据中的成对的流程数据。

[0042] 步骤15，将获取到的成对的流式数据存储至数据库。

[0043] 具体的，所有的成对的流式数据都会被存储到同一个数据库中，构建数据库表，如构建历史表和时长表，其中历史表存储逐条的流式数据，可用于后续的再次校准，包括主键id、业务id、用户id、场景id、行为类型、行为名称、行为时间字段（行为即对应于操作）；时长表存储按照规则已构建的成对的流式数据，包括主键id、业务id、用户id、场景id、行为类型、开始id、结束id、开始时间、结束时间、持续时间、创建时间字段，且开始id、开始时间对应于历史表中的开始信息数据，结束id、结束时间对应于历史表中的结束信息数据。查询特定场景特定用户的操作行为时，可以仅用单表查询出用户的每次操作行为时间，用聚合查询功能查询出用户的每天单项操作行为总时间、全部操作行为总时间等。

[0044] 可选的，在本申请一些实施例中，所述方法还包括：

[0045] 基于所述数据库中存储的数据对应的场景类型，搭建数据看板，所述数据看板支持所述数据库中所有场景类型的数据的展示；

[0046] 根据用户发起的查询请求，在所述数据看板上展示对应所述查询请求的数据。

[0047] 具体的，可使用BI分析工具metabase搭建数据看板，metabase支持连接数据库及数据查询功能。可以根据不同业务场景涉及的功能，将场景和功能作为筛选条件，筛选条件不同会构造不同的搜索语句，如where条件的sql语句；能够使用该sql语句进行数据查询并显示于所述数据看板中。

[0048] 值得注意的是，只需要搭建一次数据看板，该数据看板就能够支持其对应数据库中所有数据的查询展示，无需因为场景类型不同而为每个场景搭建单独看板，本方案中搭建的数据看板能够兼容目标应用的所有场景，并根据场景类型的不同在响应查询请求时，针对查询信息所属于的场景类型，展示对应场景相关的参数。例如，通过sql查询语句为： ，通过将业务id、用户id、场景id、创建时间作为查询条件，可以支持
不同场景不同用户的行为数据。

[0049] 综上所述，本申请实施例提供的多场景流式数据处理方法，提供了对目标应用的多场景数据流式处理方法，并且能够实现以下有益技术效果：

[0050] 通过监控流式数据日志及消息队列，实现对成对的流式数据的实时获取；

[0051] 使用统一的数据库，数据表存储获取到的成对的流式数据；

[0052] 所有成对的流式数据存储于同一数据库中，无需重复搭建数据看板，提高了数据生成效率。

[0053] 可选的，在本申请一些实施例中，所述数据处理规则，包括以下至少之一：

[0054] 根据目标场景类型下目标用户的操作行为，确定成对的流式数据；

[0055] 根据目标场景类型下目标用户的操作行为对应的时间，确定成对的流式数据；

[0056] 其中，每一种操作行为包括开始信息和结束信息，同一种操作行为的开始信息和结束信息能够组成一对流式数据。

[0057] 具体的，用户在使用不同业务功能时，会进行各种不同的操作，如视频输入功能以后开始录制、结束录制；指纹识别功能中会出现请输入指纹，输入完成，开始识别，识别通过，重新识别，识别结束等操作；支付功能中会出现开始付款、请扫付款码、出示付款码、输入付款金额、确定付款、付款结束等操作；语音识别功能中会出现开始识别、输入语音、识别结束等操作；其他的业务场景以此类推。

[0058] 值得注意的是，这些各个业务场景下，用户执行一个完整的业务功能，都会有开始操作和结束操作，如视频输入功能中的开始录制、结束录制；如指纹识别功能中的开始识别、识别结束；如支付功能中的开始付款、付款结束；如语音识别功能中的开始识别、识别结束；虽然一个业务场景下用户可以执行多种操作，但是完成一个功能必然存在着对应的开始操作和结束信息，本方案中将流式数据中每个场景下用户操作中的开始操作对应的流式数据称之为开始信息、结束操作对应的流式数据称之为结束信息；每一个业务场景下，用户要执行一个业务功能，只要用户的需要的功能得以实现，必然会出现一个开始信息、一个结束信息，因此同一种操作行为的开始信息和结束信息能够组成一对流式数据。通过流式数据的成对，能统计特定场景下用户的特定操作行为的持续时间，查询每日每周每月的用户操作次数，分析用户行为。

[0059] 可选的，在本申请一些实施例中，根据目标场景类型下目标用户操作行为对应的时间，确定成对的流式数据包括：

[0060] 当目标用户在预设时间范围内重复出现同一操作行为的多个开始信息或多个结束信息时，以最先出现的开始信息或最先出现的结束信息为准；或者以最后出现的开始信息或最后出现的结束信息为准。

[0061] 具体的，当用户连续点击同一按钮触发同一个操作，或由于网络延迟等原因，用户点击一个按钮但未及时触发对应操作导致数据未发生变更，针对以上情况，binlog日志连续传递了开始、开始，或结束、结束的开始信息和结束信息不能成对的流式数据，这时，就需要预先设置，当发生这种情况时具体按照前后操作信息的哪个操作信息作为开始信息或结束信息。

[0062] 例如，使用视频功能点击开始时，由于未知原因已记入数据库触发了binlog日志但实际未开始录制视频，此时用户再次点击更新了数据库再次触发binlog日志且实际开始视频，此时按视频实际开始时间为准，即以最后出现的信息为准；，如在另一种情况下，使用视频功能连续快速多次点击开始时，视频实际在第一次开始时间已开始，此时以最先出现的开始信息为准。各场景的具体确定规则以各场景实际情况确定。

[0063] 参考图3为用户的在语音输入下的操作对应的流式数据记录流程示意；

[0064] 用户点击开启麦克风；

[0065] 数据库设置开始时间；

[0066] binlog日志传递开始时间更新的日志1；

[0067] 保存日志1为开始信息；

[0068] 用户再次点击麦克风；

[0069] 数据库更新开始时间；

[0070] binlog日志传递开始时间更新的日志2；

[0071] 按重复操作规则确定日志1和日志2中以哪个开始时间为准，根据判断结果，更新保存的开始信息；

[0072] 用户点击关闭麦克风；

[0073] 数据库设置结束时间；

[0074] binlog日志传递结束时间更新的日志；

[0075] 保存该日志结束信息；

[0076] 匹配成对的流式数据，存储至数据库。

[0077] 可选的，在本申请一些实施例中，所述根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据包括：

[0078] 根据所述数据处理规则，并根据操作行为的开始信息和操作行为的结束信息匹配成对的流式数据，且按所述数据处理规则生成存储于所述数据库的成对的流式数据对应的实际存储数据。

[0079] 具体的，匹配并获取到成对的流式数据后，按数据处理规则中包含的数据库表信息，将成对的流式数据进行格式转化，以符合数据库表格式的要求进行存储，这种数据库表格式删除了原始流式数据中的很多冗余信息，能够极大的减轻存储压力，并提炼出成对的流式数据中的一些关键词、或者是设置标签信息，便于此后数据看板的搭建，以及便于响应数据查询请求。

[0080] 可选的，在本申请一些实施例中，所述数据处理规则还包括跨天数据规则：

[0081] 若目标成对的流式数据中的开始信息的时间与结束信息的时间跨天，将所述目标成对的流式数据拆分为两对流式数据进行保存；

[0082] 其中，开始信息至跨天0时信息为一对流式数据，跨天0时信息与结束信息为一对流式数据。具体的，当发生成对的流式数据，如开始信息在20:00，结束信息在下一天的05:00这种情况，开始信息和结束信息所处的时间存在跨天现象；这种情况需要对跨天的成对的流式数据进行跨天存储，将“开始信息在20:00，结束信息在下一天的05:00”的这对流式数据拆分成“开始信息在20:00，下一天0:00”和“下一天0:00，结束信息在下一天的05:00”两对数据来存储。

[0083] 参考图2为流式数据跨天处理流程示意：

[0084] 开启binlog日志，获取目标应用的原始流式数据；

[0085] 根据场景类型，解析对应的流式数据；

[0086] 根据场景类型对应的数据处理规则，匹配成对的流式数据；

[0087] 将解析后的流式数据发送至消息队列；

[0088] 读取场景类型对应的数据处理规则，存在跨天处理规则；

[0089] 接收消息队列中的解析后的成对的流式数据；

[0090] 判断成对的流式数据的开始信息和结束信息是否处于不同的日期；

[0091] 当成对的流式数据存在跨天现象，进行拆分存储；

[0092] 当成对的流式数据没有跨天现象，按原来的成对信息进行存储；

[0093] 根据数据库存储的所有场景的数据，搭建数据看板。

[0094] 可选的，在本申请一些实施例中，所述场景类型包括每条成对的流式数据对应的用户操作场景，至少包括以下之一：

[0095] 语音信息输入、视频信息输入、人脸识别操作、指纹识别操作、支付操作。

[0096] 具体的，场景类型还可以包括这些操作场景直播功能、会议、远程辅助、发红包、定位、转发信息、转账、播放音乐、分享文件、发起投票、收款、游戏、画图、笔记，等等各种目标应用所包含的功能对应的场景类型。

[0097] 综上所述，本申请实施例提供的多场景流式数据处理方法，通过流式数据日志及消息队列，实现对目标场景的成对的流式数据的实时获取；根据场景类型获取各场景对应的数据处理规则，根据数据处理规则确定对应场景类型的原始流式数据中的成对的流式数据，并根据数据处理规则将获取到的数据转化为相应的格式存储至统一的数据库，根据所述数据库中存储的所有场景的数据搭建数据看板，实现了将多个业务场景的流式数据按实际查询需求集成到统一数据库，搭建统一数据看板，完成多场景的数据处理及查询。

[0098] 请参考图4，本申请实施例提供了一种多场景数据流式处理系统40，包括：

[0099] 原始数据获取模块41，用于获取目标应用的原始流式数据；

[0100] 流式数据提取模块42，用于根据场景类型，从所述原始流式数据中提取所述场景类型对应的流式数据；

[0101] 多场景规则配置模块43，用于获取所述场景类型对应的数据处理规则，所述数据处理规则用于确定成对的流式数据；

[0102] 流式数据处理模块44，用于根据所述数据处理规则，获取所述场景类型对应的流式数据中的成对的流式数据；

[0103] 数据存储模块45，用于将获取到的成对的流式数据存储至数据库。

[0104] 可选的，请参考图5，在本申请一些实施例中，所述系统40还包括：

[0105] 看板搭建模块46，用于基于所述数据库中存储的数据对应的场景类型，搭建数据看板，所述数据看板支持所述数据库中所有场景类型的数据的展示；

[0106] 查询模块47，用于根据用户发起的查询请求，在所述数据看板上展示对应所述查询请求的数据。

[0107] 可选的，在本申请一些实施例中，所述流式数据处理模块44，还用于跨天数据存储：

[0108] 若目标成对的流式数据中的开始信息的时间与结束信息的时间跨天，将所述目标成对的流式数据拆分为两对流式数据进行保存；

[0109] 其中，开始信息至跨天0时信息为一对流式数据，跨天0时信息与结束信息为一对流式数据。

[0110] 可选的，在本申请一些实施例中，所述流式数据处理模块44，还用于：

[0111] 根据所述数据处理规则，并根据操作行为的开始信息和操作行为的结束信息匹配成对的流式数据，且按所述数据处理规则生成存储于所述数据库的成对的流式数据对应的实际存储数据。

[0112] 可选的，在本申请一些实施例中，所述流式数据处理模块44，还用于：

[0113] 当目标用户在预设时间范围内重复出现同一操作行为的多个开始信息或多个结束信息时，以最先出现的开始信息或最先出现的结束信息为准；或者以最后出现的开始信息或最后出现的结束信息为准。

[0114] 可选的，在本申请一些实施例中，所述数据处理规则，包括以下至少之一：

[0115] 根据目标场景类型下目标用户的操作行为，确定成对的流式数据；

[0116] 根据目标场景类型下目标用户的操作行为对应的时间，确定成对的流式数据；

[0117] 其中，每一种操作行为包括开始信息和结束信息，同一种操作行为的开始信息和结束信息能够组成一对流式数据。

[0118] 可选的，在本申请一些实施例中，所述场景类型包括每条成对的流式数据对应的用户操作场景，至少包括以下之一：

[0119] 语音信息输入、视频信息输入、人脸识别操作、指纹识别操作、支付操作。

[0120] 综上所述，本申请实施例提供的流式数据处理系统40能够实现本申请实施例提供的流式数据处理方法的全部功能和技术效果，此处不再赘述。

[0121] 请参考图6，本申请实施例还提供一种网络设备60，包括处理器61，存储器62，存储在存储器62上并可在所述处理器61上运行的计算机程序，该计算机程序被处理器61执行时实现上述多场景流式数据处理方法实施例的各个过程，且能达到相同的技术效果，为避免重复，这里不再赘述。

[0122] 本申请实施例还提供一种计算机可读存储介质，所述计算机可读存储介质上存储计算机程序，所述计算机程序被处理器执行时实现上述多场景流式数据处理方法实施例的各个过程，且能达到相同的技术效果，为避免重复，这里不再赘述。其中，所述的计算机可读存储介质，如只读存储器（Read‑Only Memory，ROM）、随机存取存储器（Random Access Memory，RAM）、磁碟或者光盘等。

[0123] 需要说明的是，在本文中，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者装置不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者装置所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括该要素的过程、方法、物品或者装置中还存在另外的相同要素。

[0124] 通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质（如ROM/RAM、磁碟、光盘）中，包括若干指令用以使得一台终端（可以是手机，计算机，服务器，空调器，或者网络设备等）执行本申请各个实施例所述的方法。

[0125] 上面结合附图对本申请的实施例进行了描述，但是本申请并不局限于上述的具体实施方式，上述的具体实施方式仅仅是示意性的，而不是限制性的，本领域的普通技术人员在本申请的启示下，在不脱离本申请宗旨和权利要求所保护的范围情况下，还可做出很多形式，均属于本申请的保护之内。