资源交互合规风险数据的回溯方法、装置和计算机设备

    公开(公告)号:CN118916388A

    公开(公告)日:2024-11-08

    申请号:CN202410935691.8

    申请日:2024-07-12

    摘要: 本申请涉及大数据领域,具体公开了一种资源交互合规风险数据的回溯方法、装置、计算机设备、计算机可读存储介质和计算机程序产品。所述方法包括:获取初始资源数据,并建立初始资源数据的第一处理线程和第二处理线程;响应于资源交互请求,利用第一处理线程,根据初始资源数据,对所述资源交互请求进行合规风险检测,得到资源交互请求的检测结果;利用第二处理线程,根据资源交互请求,获取资源交互请求风险检测过程中初始资源数据的变更数据;根据资源交互请求,获取变更数据对应的标识信息;建立变更数据和对应的标识信息的关联信息,得到资源交互请求的回溯数据。采用本方法能够保证合规风险检测的效率和回溯数据加工的低延迟。

    一种批量任务处理方法、装置、设备和存储介质

    公开(公告)号:CN110806933B

    公开(公告)日:2022-06-10

    申请号:CN201911072107.6

    申请日:2019-11-05

    IPC分类号: G06F9/48 G06F9/50

    摘要: 本发明实施例公开了一种批量任务处理方法、装置、设备和存储介质,批量任务处理方法包括:获取待执行的批量任务队列,其中,批量任务队列由至少一个待执行任务组成;确定批量任务队列中的目标任务的执行步骤;若根据执行步骤的步骤属性确定存在至少两个可并列执行步骤,则将所述至少两个可并列执行步骤分配至至少两个执行节点,以执行批量任务队列中的所述目标任务。本发明实施例将目标任务中可并列执行的步骤同时分配给不同的执行节点,避免对于单个任务的每个执行步骤都需要进行顺序执行,减少目标任务的执行时间。多执行节点并发处理任务提高批量任务处理的效率,并实现均衡各个执行节点的任务分配的效果。

    一种风险指令撤销的处理方法、装置以及计算机设备

    公开(公告)号:CN118552321A

    公开(公告)日:2024-08-27

    申请号:CN202410811665.4

    申请日:2024-06-21

    IPC分类号: G06Q40/06 G06Q20/40

    摘要: 本申请涉及数据处理技术领域,特别是涉及一种风险指令撤销的处理方法、装置、计算机设备、存储介质和计算机程序产品。所述方法包括:响应于目标指令的撤销处理,获取所述目标指令的指令批次以及相关联的指标检查进度;确定与所述目标指令对应的关联指标,并基于所述撤销处理对所述关联指标进行回退修正;根据所述指标检查进度、所述指令批次以及所述关联指标,确定与所述关联指标相关联的待检查指令,所述待检查指令的风险检查结果与所述关联指标相关;基于回退修正后的所述关联指标对所述待检查指令进行风险检查。采用本方法能够提高风险指令撤销的处理效率。

    指令合规检测方法、装置、计算机设备、可读存储介质和程序产品

    公开(公告)号:CN118535225A

    公开(公告)日:2024-08-23

    申请号:CN202410763172.8

    申请日:2024-06-13

    IPC分类号: G06F9/30

    摘要: 本申请涉及一种指令合规检测方法、装置、计算机设备、计算机可读存储介质和计算机程序产品,涉及大数据领域。该方法包括:若检测到第一交易指令,则定位第一交易指令对应的目标第二层级应用,以及目标第二层级应用关联的X个第一层级应用;获取X个第一层级应用在响应第一交易指令前的第一检测指标数据,以及目标第二层级应用在响应第一交易指令后的第二检测指标数据;根据第一检测指标数据、第二检测指标数据以及X个第一层级应用对于目标第二层级应用的数据资源占有信息,生成X个第一层级应用在响应第一交易指令后的目标检测指标数据;根据目标检测指标数据,检测第一交易指令是否合规。采用本方法能够提升交易指令合规检测的效率。

    一种批量任务处理方法、装置、设备和存储介质

    公开(公告)号:CN110806933A

    公开(公告)日:2020-02-18

    申请号:CN201911072107.6

    申请日:2019-11-05

    IPC分类号: G06F9/48 G06F9/50

    摘要: 本发明实施例公开了一种批量任务处理方法、装置、设备和存储介质,批量任务处理方法包括:获取待执行的批量任务队列,其中,批量任务队列由至少一个待执行任务组成;确定批量任务队列中的目标任务的执行步骤;若根据执行步骤的步骤属性确定存在至少两个可并列执行步骤,则将所述至少两个可并列执行步骤分配至至少两个执行节点,以执行批量任务队列中的所述目标任务。本发明实施例将目标任务中可并列执行的步骤同时分配给不同的执行节点,避免对于单个任务的每个执行步骤都需要进行顺序执行,减少目标任务的执行时间。多执行节点并发处理任务提高批量任务处理的效率,并实现均衡各个执行节点的任务分配的效果。

    文件解析入库、文件生成方法及装置

    公开(公告)号:CN111339041A

    公开(公告)日:2020-06-26

    申请号:CN202010161768.2

    申请日:2020-03-10

    发明人: 母睿 邓昌胜

    IPC分类号: G06F16/16 G06F16/172

    摘要: 本公开涉及一种文件解析入库、文件生成方法及装置,该文件解析入库方法包括:确定待解析入库文件的文件类型;确定所述文件类型对应的数据解析配置和文件格式映射规则;根据所述数据解析配置和所述文件格式映射规则对所述待解析入库文件进行解析并存储到数据库表中。本发明的文件解析入库、文件生成方法具有以下优点:可通过灵活的配置支持数据文件的解析和导出工作;支持多种数据交换协议且可灵活自定义文件格式;支持大批量数据的多线程、多并发的分布式导出;支持切片式的多并发分布式解析;可扩展、可配置的解析入库和导出实现;支持文件解析和数据文件导出的有效性校验。

    用于将大数据量的文本文件导入分布式数据库的方法及装置

    公开(公告)号:CN112597219A

    公开(公告)日:2021-04-02

    申请号:CN202011481442.4

    申请日:2020-12-15

    IPC分类号: G06F16/25 G06F9/50 G06F16/27

    摘要: 本发明涉及用于将大数据量的文本文件导入分布式数据库的方法和装置,其特征在于,所述方法具有下列步骤:查询并获取文件导入参数配置;将所述大数据量的文本文件以数据量平均的方式分成多个文件读取子区域;以对应数量的线程拆分所有文件读取子区域,其中,每个文件读取子区域中的数据分别被拆分到同等数量的多个子文件中;将拆分后得到的所有子文件分配给多个分布式AP;使用多线程异步外呼发送文件导入请求至各分布式AP,并且各分布式AP分别以分配到的子文件个数发起对应数量的线程进行文件导入,其中,按照拆分后的子文件的编号并发导入到各分表中。此外,本发明还涉及用于将大数据量的文本文件导入分布式数据库的装置。

    文件解析入库、文件生成方法及装置

    公开(公告)号:CN111339041B

    公开(公告)日:2024-01-12

    申请号:CN202010161768.2

    申请日:2020-03-10

    发明人: 母睿 邓昌胜

    IPC分类号: G06F16/16 G06F16/172

    摘要: 本公开涉及一种文件解析入库、文件生成方法及装置,该文件解析入库方法包括:确定待解析入库文件的文件类型;确定所述文件类型对应的数据解析配置和文件格式映射规则;根据所述数据解析配置和所述文件格式映射规则对所述待解析入库文件进行解析并存储到数据库表中。本发明的文件解析入库、文件生成方法具有以下优点:可通过灵活的配置支持数据文件的解析和导出工作;支持多种数据交换协议且可灵活自定义文件格式;支持大批量数据的多线程、多并发的分布式导出;支持切片式的多并发分布式解析;可扩展、可配置的解析入库和导出实现;支持文件解析和数据文件导出的有效性校验。

    产品限额控制方法、装置、电子设备和计算机可读介质

    公开(公告)号:CN113344706A

    公开(公告)日:2021-09-03

    申请号:CN202110687219.3

    申请日:2021-06-21

    发明人: 母睿 邓昌胜

    IPC分类号: G06Q40/04 G06Q30/02 G06F16/27

    摘要: 本发明公开了一种产品限额控制方法、装置、电子设备和计算机可读介质,涉及自动程序设计技术领域。其中,该方法包括:判断目标产品的交易申请量是否超出当前最大可受理额度;若是,从各个分库中筛选出部分交易申请记录,并将从各个分库中筛选出的交易申请记录汇总至主库;从汇总至主库的交易申请记录中筛选出部分交易申请记录,并将筛选出的交易申请记录确认为有效。通过以上步骤,能够提高产品限额控制的处理效率,降低产品限额控制对系统资源的占用,提高系统性能。

    一种数据处理方法、装置、设备及介质

    公开(公告)号:CN114116317A

    公开(公告)日:2022-03-01

    申请号:CN202111440418.0

    申请日:2021-11-30

    IPC分类号: G06F11/14

    摘要: 本申请涉及数据存储技术领域,提供一种数据处理方法、装置、设备及介质,用于提高数据备份的效率。该方法包括:接收数据备份请求,获取包括多行数据的待备份数据表;确定所述待备份数据表的第一标识,基于所述第一标识确定一级分区;根据预存的第一参数和所述多行数据中每一行数据的哈希码,确定每一行数据的第二标识;同时启动多个线程,基于每一行数据的第二标识,分别将每一行数据备份至所述一级分区中对应的二级分区中。本申请实施例中同时启动多个线程进行并发备份,可以提高数据备份的效率。