本申请涉及互联网金融风控,特别是一种基于redis缓存的风控实时计算方法及装置。
背景技术:
1、通常互联网金融公司的支付相关业务,都需要进行特定的风险控制来规避交易过程中可能发生的欺诈行为。基于规则判断的风控技术方案,最核心的技术点在于如何极快速的计算出特定维度下的所有交易金额和交易笔数的统计。最早的风控系统会基于传统的关系型数据库来进行统计,这样技术成本虽然低,但是风控计算的效率也是最低的,随着支付业务场景的蓬勃发展,这种基于传统关系型数据库的计算速度完全无法满足业务需求。为了解决此类问题,就需要在交易完成之后,实时地对交易数据进行计算统计后并落库存储,为下一次交易发生时做好实时的规则判断。
2、现有的实时风控解决方案中,通常使用flink、sparkstream和kafkastream等实时计算框架,这些框架功能复杂且完善,但是使用和维护的技术成本和it成本却非常高。
技术实现思路
1、鉴于所述问题,提出了本申请以便提供克服所述问题或者至少部分地解决所述问题的一种基于redis缓存的风控实时计算方法及装置,包括:
2、一种基于redis缓存的风控实时计算方法,所述方法包括:
3、在所述redis缓存中构建有序集合和散列集合;其中,所述有序集合中存有所有账户的当天交易信息;所述散列集合中存有时段交易信息;所述时段交易信息包括所有时间段区间的统计信息;
4、当接收到目标交易的交易详情数据时,依据所述交易详情数据更新所述目标交易对应的目标时间段区间的交易信息。
5、进一步地,所述依据所述交易详情数据更新所述目标交易对应的所述目标时间段区间的交易信息的步骤,包括:
6、依据所述交易详情数据在所述散列集合中确定所述目标交易对应的所述目标时间段区间;
7、将所述交易详情数据的交易额和交易笔数累加入所述目标时间段区间的交易信息中。
8、进一步地,所述方法还包括:
9、当接收到交易的交易详情数据时,依据所述交易详情数据更新所述目标交易对应的账户的当天交易信息;
10、当接收到交易风控计算信号时,获取设置在风控配置平台风控规则信息;
11、依据所述风控规则信息和所述交易详情数据在所述redis缓存中查询对应的统计数据;
12、依据所述风控规则评估所述统计数据确定所述目标交易的风险。
13、进一步地,所述依据所述交易详情数据更新所述目标交易对应的账户的当天交易信息的步骤,包括:
14、依据所述交易详情数据确定所述目标交易对应的账户在所述有序集合中对应的目标集合;
15、依据所述交易详情数据更新所述目标集合中的所述交易信息。
16、进一步地,所述依据所述风控规则信息和所述交易详情数据在所述redis缓存中查询对应的统计数据的步骤,包括:
17、依据所述风控规则信息确定目标数据存储集合;
18、依据所述风控规则信息在所述目标数据存储集合中获取所述交易详情数据对应的目标统计数据。
19、进一步地,所述依据所述风控规则信息在所述目标数据存储集合中获取所述交易详情数据对应的目标统计数据的步骤,包括:
20、当所述目标数据存储集合为所述散列集合时,依据所述风控规则信息和所述交易详情数据确定目标时间区段;
21、依据所述目标时间区段在所述散列集合中查询并获取所述目标统计数据;
22、当所述目标数据存储集合为所述有序集合时,依据所述风控规则信息和所述交易详情数据在所述有序集合中查询并获取所述目标统计数据。
23、进一步地,所述依据所述风控规则评估所述统计数据确定所述目标交易的风险的步骤,包括:
24、依据所述风控规则信息评估所述统计数据,当满足条件时继续交易,否则终止交易。
25、一种基于redis缓存的风控实时计算装置,所述装置包括:
26、存储集合构建模块,用于在所述redis缓存中构建有序集合和散列集合;其中,所述有序集合中存有所有账户的当天交易信息;所述散列集合中存有时段交易信息;所述时段交易信息包括所有时间段区间的统计信息;
27、时段交易信息写入模块,用于当接收到目标交易的交易详情数据时,依据所述交易详情数据更新所述目标交易对应的目标时间段区间的交易信息。
28、一种设备,包括处理器、存储器及存储在所述存储器上并能够在所述处理器上运行的计算机程序,所述计算机程序被所述处理器执行时实现如上所述的基于redis缓存的风控实时计算方法的步骤。
29、一种计算机可读存储介质,所述计算机可读存储介质上存储计算机程序,所述计算机程序被处理器执行时实现如上所述的基于redis缓存的风控实时计算方法的步骤。
30、本申请具有以下优点:
31、在本申请的实施例中,相对于现有技术中的使用和维护的技术成本和it成本非常高的问题,本申请提供了基于时间段区间切割的hash存储的解决方案,具体为:在所述redis缓存中构建有序集合和散列集合;其中,所述有序集合中存有所有账户的当天交易信息;所述散列集合中存有时段交易信息;所述时段交易信息包括所有时间段区间的统计信息;当接收到目标交易的交易详情数据时,依据所述交易详情数据更新所述目标交易对应的目标时间段区间的交易信息。通过依据时间段区间存储交易信息的统计信息,解决了运维it和技术成本非常高的问题,达到了以极低的it和技术成本,就将交易风控系统的响应时间从每笔请求平均耗时500ms提升至5ms,请求处理效率提升100倍,满足了复杂的实时计算业务场景需要。
1.一种基于redis缓存的风控实时计算方法,其特征在于,所述方法包括:
2.根据权利要求1所述的方法,其特征在于,所述依据所述交易详情数据更新所述目标交易对应的所述目标时间段区间的交易信息的步骤,包括:
3.根据权利要求1所述的方法,其特征在于,所述方法还包括:
4.根据权利要求3所述的方法,其特征在于,所述依据所述交易详情数据更新所述目标交易对应的账户的当天交易信息的步骤,包括:
5.根据权利要求3所述的方法,其特征在于,所述依据所述风控规则信息和所述交易详情数据在所述redis缓存中查询对应的统计数据的步骤,包括:
6.根据权利要求5所述的方法,其特征在于,所述依据所述风控规则信息在所述目标数据存储集合中获取所述交易详情数据对应的目标统计数据的步骤,包括:
7.根据权利要求3所述的方法,其特征在于,所述依据所述风控规则评估所述统计数据确定所述目标交易的风险的步骤,包括:
8.一种基于redis缓存的风控实时计算装置,其特征在于,所述装置包括:
9.一种设备,其特征在于,包括处理器、存储器及存储在所述存储器上并能够在所述处理器上运行的计算机程序,所述计算机程序被所述处理器执行时实现如权利要求1至7中任一项所述的方法。
10.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质上存储计算机程序,所述计算机程序被处理器执行时实现如权利要求1至7中任一项所述的方法。