文献类型：专利

专利类型：发明专利

是否失效：否

是否授权：否

申 请 号：CN202210808773.7

申 请 日：20220708

发 明 人：曾志强 杨兢

申 请 人：深圳金融电子结算中心有限公司

申请人地址：518000 广东省深圳市福田区车公庙泰然六路501栋

公 开 日：20250902

公 开 号：CN115170267B

代 理 人：戴圆圆

代理机构：深圳市恒程创新知识产权代理有限公司 44542

语　　种：中文

摘　　要：本发明公开了一种基于Pika的对账方法、基于Pika的对账设备及存储介质，属于交易数据处理技术领域。本发明通过获取本地的第一交易数据及其对应的渠道交易数据，所述渠道交易数据为外部系统的交易数据，所述第一交易数据和所述渠道交易数据均为预设时间段内的用户交易数据；导入所述第一交易数据和所述渠道交易数据到Pika；通过所述Pika的分析命令确定所述第一交易数据和所述渠道交易数据之间的差异数据，实现减少对账过程数据处理所使用的内存。

主 权 项：1.一种基于Pika的对账方法，其特征在于，所述基于Pika的对账方法包括以下步骤：获取本地的第一交易数据及其对应的渠道交易数据，所述渠道交易数据为外部系统的交易数据，所述第一交易数据和所述渠道交易数据均为预设时间段内的用户交易数据；导入所述第一交易数据和所述渠道交易数据到Pika；获取本地的第二交易数据，所述第二交易数据为所述预设时间段之前的用户交易数据；根据所述第二交易数据确定所述第一交易数据和所述渠道交易数据的分片数；根据预设容量切分所述第一交易数据获得多个第一子数据，根据所述预设容量切分所述渠道交易数据获得多个第二子数据；对所述多个第一子数据和所述多个第二子数据进行取模运算，根据取模运算结果分配所述Pika的对应槽位，所述多个第一子数据和所述多个第二子数据通过对应的槽位分配到对应的线程，其中，根据分片数将数据分配给对应的线程，根据所需的线程条数构造线程池；通过所述Pika的分析命令确定所述第一交易数据和所述渠道交易数据之间的差异数据，具体包括：根据槽位分配对应的线程，在所述线程内执行所述分析命令；通过所述分析命令确定所述第一子数据和所述渠道交易数据的交集、所述第一子数据和所述交集的第一差集以及所述渠道交易数据和所述交集的第二差集，其中，所述差异数据包括所述第一差集和所述第二差集。

关 键 词：Pika  对账 存储介质 交易数据 渠道  外部系统  预设时间段  用户交易数据  导入  数据确定  片数  容量  切分 数据获得  子数据  取模运算  结果分配  槽位  数据通过  线程 数据分配 条数  线程池 分析  命令确定  差异数据  执行  分析命令  交集  数据包括  

IPC专利分类号：G06Q 40/12;G06F 3/06