(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210707055.0 (22)申请日 2022.06.21 (71)申请人 平安银行股份有限公司 地址 518000 广东省深圳市罗湖区深南 东 路5047号 (72)发明人 龚文涛　 (74)专利代理 机构 深圳中一联合知识产权代理 有限公司 4 4414 专利代理师 刘永康 (51)Int.Cl. G06F 16/25(2019.01) G06Q 20/38(2012.01) G06Q 40/02(2012.01) (54)发明名称 交易流水处理方法、 装置、 设备及存 储介质 (57)摘要 本申请涉及风控 领域， 提出了一种交易流水 处理方法、 装置、 设备及存储介质。 该方法包括： 获取当前时间的待处理的交易流水； 确定用于对 所述交易流水进行处理的查询脚本； 在预先确定 的历史交易数据库中， 查找与所述交易流水相关 的历史交易数据； 将查找的历史交易数据与所述 待处理的交易流水合并， 通过流式计算引擎的报 送接口， 按照窗口模式将合并数据写入内存数据 库； 根据预先确定的风控算子， 对所述窗口模式 中的待处理的交易流水和历史交易数据进行风 控计算， 确定所述待处理的交易流水的风控信 息。 本申请通过窗口模式对包括历史交易数据和 当前的交易流水的合并数据进行风控计算， 因而 能够更为 准确的确定交易 流水的风险信息 。 权利要求书2页 说明书9页 附图2页 CN 115062079 A 2022.09.16 CN 115062079 A 1.一种交易 流水处理方法， 其特 征在于， 所述方法包括： 获取当前时间的待处 理的交易 流水； 调用流式计算引擎的查询接口， 确定用于对所述交易 流水进行处 理的查询脚本； 根据所确定的查询脚本， 在预先确定的历史交易数据库中， 查找与所述交易流水相关 的历史交易数据； 将查找的历史交易数据与所述待处理的交易流水合并， 通过流式计算引擎的报送接 口， 按照窗口模式将合并数据写入内存数据库； 根据预先确定的风控算子， 对所述 窗口模式中的待处理 的交易流水和历史交易数据进 行风控计算， 确定所述待处 理的交易 流水的风控信息 。 2.根据权利要求1所述的方法， 其特征在于， 调用流式计算引擎的查询接口， 确定用于 对所述待处 理的交易 流水进行处 理的查询脚本， 包括： 调用流式计算引擎的查询接口， 获取 所述交易 流水的数据信息； 根据所述待处 理的交易 流水的数据信息， 确定用于处 理所述交易 流水的查询脚本 。 3.根据权利要求1所述的方法， 其特征在于， 根据所确定的查询脚本， 在预先确定的历 史交易数据库中， 查找与所述交易流水相关的历史交易数据， 包括以下方式中的一项或者 多项： 根据所述查询脚本， 在预先确定的历史交易数据库中， 查找与所述交易流水的交易账 户相关的历史 交易数据； 根据所述查询脚本， 在预先确定的历史交易数据库中， 查找与所述交易流水的交易时 间相关的历史 交易数据； 根据所述查询脚本， 在预先确定的历史交易数据库中， 查找与所述交易流水的IP地址 相关的历史 交易数据； 根据所述查询脚本， 在预先确定的历史交易数据库中， 查找与所述交易流水的交易金 额相关的历史 交易数据。 4.根据权利要求1所述的方法， 其特征在于， 按照窗口模式将合并数据写入内存数据 库， 包括： 按照预定的窗口模式获取 所述合并数据； 将所述合并数据置换为 位图数据， 通过位图数据将合并数据缓存至内存数据库。 5.根据权利要求4所述的方法， 其特征在于， 通过位图数据将合并数据缓存至 内存数据 库， 包括： 获取待写入内存数据库中的单 条数据的大小； 在待写入内存数据库中的单条数据的大小大于所述内存数据库的可用空闲空间大小 时， 根据所述内存数据库中存 储的位图分片的时间， 删除时间最 早的位图分片的数据。 6.根据权利要求1所述的方法， 其特征在于， 根据预先确定的风控算子， 对所述窗口模 式中的待处 理的交易 流水和历史 交易数据进行风控计算， 包括： 根据预先确定的风控算子触发相应的风控计算进程； 根据触发的多个风控计算进程， 对所述交易流水和所述历史交易数据进行并行计算处 理。 7.根据权利要求1或6任一项所述的方法， 其特征在于， 所述风控算子包括计数风控因权　利　要　求　书 1/2 页 2 CN 115062079 A 2子、 求和风控因子、 去重集 合风控因子、 方差风控因子、 标准差风控因子中的一项或者多 项。 8.一种交易 流水处理装置， 其特 征在于， 所述装置包括： 交易流水获取 单元， 用于获取当前时间的待处 理的交易 流水； 脚本查询单元， 用于调用流式计算引擎的查询接口， 确定用于对所述交易流水进行处 理的查询脚本； 历史交易数据查找单元， 用于根据所确定的查询脚本， 在预先确定的历史交易数据库 中， 查找与所述交易 流水相关的历史 交易数据； 数据合并单元， 用于将查找的历史交易数据与所述待处理的交易流水合并， 通过流式 计算引擎的报送接口， 按照窗口模式将合并数据写入内存数据库； 风控单元， 用于根据预先确定的风控算子， 对所述窗口模式中的待处理的交易流水和 历史交易数据进行风控计算， 确定所述待处 理的交易 流水的风控信息 。 9.一种交易流水处理设备， 包括存储器、 处理器以及存储在所述存储器中并可在所述 处理器上运行 的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现如权利 要求1至7任一项所述方法的步骤。 10.一种计算机可读存储介质， 所述计算机可读存储介质存储有计算机程序， 其特征在 于， 所述计算机程序被处 理器执行时实现如权利要求1至7任一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115062079 A 3