(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210947228.6 (22)申请日 2022.08.09 (71)申请人 中企云链 （北京） 金融信息服 务有限 公司 地址 100043 北京市石景山区石景山路31 号院盛景国际广场3号楼 918室 (72)发明人 王明志　 (51)Int.Cl. G06F 16/2457(2019.01) G06F 16/2458(2019.01) G06Q 40/02(2012.01) (54)发明名称 基于FLINK处理引擎的用户行为分析方法及 系统 (57)摘要 本发明提供一种基于FLINK处理引擎的用户 行为分析方法及系统， 所述方法包括： 服务器端 接收来自在客户端收集的用户行为数据， 用户行 为数据包括： 用户身份信息、 云信开立业务系统 行为信息和融资业务系统行为信息； 服务器端基 于用户行为数据得到数据模型， 数据模型用于分 析用户从云信开立业务到融资业务的转换率和/ 或分析业务流程； 服务器端将数据模型存储和/ 或发送至指定目标。 该方法收集用户在云信开立 业务流程和融资业务流程上的数据信息， 对这些 数据进行分析 获得数据模型， 该数据模型可形成 报表或者可视化图表； 通过对数据模型的分析， 可优化业务流程， 优化云信平台的云信开立业务 流程和融资业务流程， 以提高用户从云信开立到 融资的转换率。 权利要求书2页 说明书9页 附图4页 CN 115017201 A 2022.09.06 CN 115017201 A 1.一种基于FLINK处理引擎的用户行为分析方法， 其特征在于， 所述方法包括如下步 骤： 服务器端接收来自在客户端收集的用户行为数据， 所述用户行为数据包括： 用户身份 信息、 云信开 立业务系统行为信息和融资业 务系统行为信息； 所述服务器端基于所述用户行为数据得到数据模型， 所述数据模型用于分析用户从云 信开立业务到融资业 务的转换率和/或分析业 务流程； 所述服务器端将所述数据模型存 储和/或发送至指定目标。 2.根据权利要求1所述的基于FLINK处理引擎的用户行为分析方法， 其特征在于， 客户 端的云信平台包括云信开立业务系统和融资业务系统， 所述云信开立业务系统用于用户的 云信开立业务， 所述融资业 务系统用于用户的融资业 务； 在所述客户端收集的所述用户行为数据包括： 在所述云信平台采集的所述用户身份信 息； 在云信开立业务系统获得的所述云信开立业务系统行为信息包括： 用户 进入页面时 间、 用户退 出页面时间、 当前页面路径、 当前页面 点击的元 素信息； 在融资业务系统获得的所述融资业务系统行为信息包括： 用户进入融资页面时间、 用 户退出融资页面时间、 当前页面路径、 当前页面 点击的元 素信息。 3.根据权利要求2所述的基于FLINK处理引擎的用户行为分析方法， 其特征在于， 在所 述服务器端接收来自在客户端收集的用户行为数据的步骤之前， 所述方法还 包括： 所述客户端的云信开立业务系统和融资业务系统分别在等间隔的设定周期将所述用 户行为数据推送至KAF KA中。 4.根据权利 要求2或3所述的基于FLINK处理引擎的用户行为分析方法， 其特征在于， 所 述服务器端基于所述用户行为数据得到数据模型的步骤 包括： 所述服务器端通过KAFKA接收用户在所述云信平台的所述用户行为数据到FLINK处理 引擎中， KAF KA用于对所述用户行为数据进行去重以及过 滤垃圾数据； FLINK处理引擎基于所述用户行为数据的路径URL和名称确认该用户行为数据归属的 业务系统， 不同的业 务系统的所述用户行为数据对应不同业 务的数据模型。 5.根据权利要求4所述的基于FLINK处理引擎的用户行为分析方法， 其特征在于， 所述 FLINK处理引擎对KAF KA中的所述用户行为数据进行计算汇总， 包括如下步骤： 将用户退 出页面时间减去用户进入页面时间算出用户访问该业 务系统的时长信息； 将用户在当前页面点击的元素信息封装为具体时间段的操作习惯及业务流程数据模 型； 将所述具体时间段的操作习惯及业 务流程数据模型SI NK到DORIS中。 6.根据权利要求5所述的基于FL INK处理引擎的用户行为分析 方法， 其特 征在于， 在将所述具体时间段的操作习惯及业务流程数据模型SINK到DORIS中后， 通过定时任 务XXLJOB将用户的所述具体时间段的操作习惯及业务流程数据模型再进行汇总生成整体 连贯的用户行为数据； 将汇总的整体连贯的用户行为数据保存到 MYSQL和/或REDIS提供查询功能。 7.根据权利要求6所述的基于FL INK处理引擎的用户行为分析 方法， 其特 征在于， 基于所述用户行为数据获得 所有用户从云信开 立业务到融资业 务中间页面的退 出率：权　利　要　求　书 1/2 页 2 CN 115017201 A 2退出率=退出次数／总访问量*10 0%； 基于所述用户行为数据获得 所有用户从云信开 立业务到融资业 务中间页面的转换率： 转换率=所有用户从云信开立业务到融资业务完成的总数／所有用户完成云信开立业 务总数*10 0%； 其中， 所述退出率和转换率用于分析业务系统 的业务流程问题或者收集到的用户行为 数据异常问题。 8.一种基于FL INK处理引擎的用户行为分析系统， 其特 征在于， 所述系统包括： 客户端， 用于采集用户在云信平台上的用户行为数据， 所述云信平台包括云信开立业 务系统和融资业务系统， 所述云信开立业务系统用于用户的云信开立业务， 所述融资业务 系统用于用户的融资业务； 在云信开立业务系统获得的所述云信开立业务系统行为信息包 括： 用户进入页面时间、 用户退出页面时间、 当前页面路径、 当前页面点击的元素信息； 在融 资业务系统获得的所述融资业务系统行为信息包括： 用户进入融资页面时间、 用户退出融 资页面时间、 当前页面路径、 当前页面 点击的元 素信息； 服务器端， 用于接收来自在客户端收集的用户行为数据， 基于所述用户行为数据得到 数据模型， 所述数据模型用于分析用户从云信开立业务到融资业务的转换率和/或分析业 务流程； 所述服务器端用于将所述数据模型存 储和/或发送至指定目标。 9.一种基于FLINK处理引擎的用户行为分析装置， 包括处理器和存储器， 其特征在于， 所述存储器中存储有计算机指令， 所述处理器用于执行所述存储器中存储的计算机指令， 当所述计算机指 令被处理器执行时， 该装置实现如权利要求 1至7中任意一项 所述方法的步 骤。 10.一种计算机可读取存储介质， 其上存储有计算机程序， 其特征在于， 该程序被处理 器执行时实现如权利要求1至7中任意 一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115017201 A 3