资源处理方法、系统、电子装置和存储介质.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115686869A(43)申请公布日2023.02.03(21)申请号202211700922.4(22)申请日2022.12.29(71)申请人杭州迈拓大数据服务有限公司地址310021浙江省杭州市江干区同协路1279号西子智慧产业园16号楼306室(72)发明人季山俞怿梦(74)专利代理机构杭州华进联浙知识产权代理有限公司33250专利代理师方道杰(51)Int.Cl.G06F9/50(2006.01)G06Q40/12(2023.01)权利要求书3页说明书12页附图6页(54)发明名称资源处理方法、系统、电子装置和存储介质(57)摘要本申请涉及一种资源处理方法、系统、电子装置和存储介质，根据数据流中各资源在过去n个流转日的日流转量，确定各资源的流动性，其中，数据流包括对应于各资源的逐笔数据；将流动性不低于第一阈值的资源的逐笔数据分发至第一处理单元，将流动性低于第一阈值的资源的逐笔数据分发至第二处理单元，其中，第一处理单元的处理性能高于第二处理单元的处理性能；分别根据第一处理单元和第二处理单元，对分发的逐笔数据进行融合，得到对应于各资源的资源账簿，解决了资源处理过程中计算资源利用率不高的问题，提高了资源处理过程中的计算资源利用率。CN115686869ACN115686869A权利要求书1/3页1.一种资源处理方法，其特征在于，包括：根据数据流中各资源在过去n个流转日的日流转量，确定各所述资源的流动性，其中，所述数据流包括对应于各所述资源的逐笔数据；将流动性不低于第一阈值的资源的逐笔数据分发至第一处理单元，将流动性低于第一阈值的资源的逐笔数据分发至第二处理单元，其中，所述第一处理单元的处理性能高于所述第二处理单元的处理性能；分别根据所述第一处理单元和所述第二处理单元，对分发的逐笔数据进行融合，得到对应于各所述资源的资源账簿。2.根据权利要求1所述的资源处理方法，其特征在于，根据所述数据流中各资源在过去n个流转日的日流转量，确定各所述资源的流动性，包括：获取各所述资源在过去n个流转日的日流转量的中位数；对各所述资源在过去n个流转日的日流转量的中位数，取自然对数，得到各所述资源的流动性。3.根据权利要求2所述的资源处理方法，其特征在于，确定所述第一阈值包括：根据所述n个流转日确定自由度；获取t分布临界值表，根据所述自由度和预设分位点，在所述t分布临界值表中确定目标t值；计算各所述资源的流动性的期望值和标准差，并根据所述目标t值、各所述资源的流动性的期望值和标准差，计算得到所述第一阈值。4.根据权利要求1所述的资源处理方法，其特征在于，所述第一处理单元的时钟频率，高于所述第二处理单元的时钟频率；或者，所述第一处理单元的单位处理数据上限值，高于所述第二处理单元的单位处理数据上限值；或者，所述第一处理单元当前所处理的资源份数，少于所述第二处理单元当前所处理的资源份数。5.根据权利要求1所述的资源处理方法，其特征在于，所述资源账簿包括：委托标识、委托的状态和价格档位信息。6.根据权利要求5所述的资源处理方法，其特征在于，分别根据所述第一处理单元和所述第二处理单元，对分发的逐笔数据进行融合，得到对应于各所述资源的资源账簿，包括：根据所述逐笔数据携带的委托标识，确定对应的目标委托；根据所述逐笔数据所属的业务类型，维护所述目标委托和对应资源的价格档位信息。7.根据权利要求6所述的资源处理方法，其特征在于，根据所述逐笔数据所属的业务类型，维护所述目标委托和对应资源的价格档位信息，包括：当所述逐笔数据的业务类型为委托申报时，记录所述逐笔数据携带的委托标识和初始状态，并更新和所述目标委托处于同一价格档位上其余委托的状态；或者，当所述逐笔数据的业务类型为委托修改时，更新所述目标委托的状态，并更新和所述目标委托处于同一价格档位上其余委托的状态；或者，当所述逐笔数据的业务类型为委托撤销时，删除所述目标委托，并更新和所述目标委托处于同一价格档位上其余委托的状态；或者，2CN115686869A权利要求书2/3页当所述逐笔数据的业务类型为成交时，更新所述目标委托的状态，并更新和所述目标委托处于同一价格档位上其余委托的状态。8.根据权利要求5所述的资源处理方法，其特征在于，所述资源账簿还包括所述逐笔数据，所述逐笔数据存储于持久化存储区。9.根据权利要求8所述的资源处理方法，其特征在于，将所述逐笔数据写入所述持久化存储区，包括：在所述数据流存在故障的情况下，封存所述数据流中各所述资源的资源账簿；将故障时点后到达的数据流存储至内存中；在接收到所述故障时点的数据流的增补文件的情况下，根据所述增补文件和所述故障时点后到达的数据流，对所封存的资源账簿进行修复，直至所修复的资源账簿的时间戳与当前接收到的数