一种索引数据的构建方法和装置.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN114860721A(43)申请公布日2022.08.05(21)申请号202210445890.1(22)申请日2022.04.26(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人蒲腾飞(74)专利代理机构中原信达知识产权代理有限责任公司11219专利代理师郭晗赵迪(51)Int.Cl.G06F16/22(2019.01)G06F16/23(2019.01)权利要求书3页说明书12页附图9页(54)发明名称一种索引数据的构建方法和装置(57)摘要本发明公开了一种索引数据的构建方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：通过统一的数据采集接口接收源系统中业务数据的变更数据，变更数据包括业务数据的业务标识和业务变更字段；将变更数据按照预设结构写入到第一数据库，并在变更数据写入成功后，生成变更消息，变更消息包括业务数据的业务标识；响应于生成变更消息，根据变更消息中的业务标识，从第一数据库中查询用于生成索引的字段，以由查询到的字段组装得到索引数据。该实施方式能够实现数据写入的统一控制，解决了新数据被旧数据覆盖的问题，提高数据写入的准确率和效率，降低对系统的性能要求。CN114860721ACN114860721A权利要求书1/3页1.一种索引数据的构建方法，其特征在于，包括：通过统一的数据采集接口接收源系统中业务数据的变更数据，所述变更数据包括所述业务数据的业务标识和业务变更字段；将所述变更数据按照预设结构写入到第一数据库，并在所述变更数据写入成功后，生成变更消息，所述变更消息包括所述业务数据的业务标识；响应于生成所述变更消息，根据所述变更消息中的业务标识，从所述第一数据库中查询用于生成索引的字段，以由查询到的字段组装得到索引数据。2.根据权利要求1所述的方法，其特征在于，所述变更数据还包括所述业务数据的数据版本号；所述通过统一的数据采集接口接收源系统中业务数据的变更数据，包括：以业务标识、数据版本号、业务变更字段作为所述统一的数据采集接口的接口参数，接收所述源系统中业务数据的变更数据。3.根据权利要求2所述的方法，其特征在于，所述通过统一的数据采集接口接收源系统中业务数据的变更数据之后，包括：对接收的所述源系统中业务数据的变更数据进行字段验证，以确认接收的所述源系统中业务数据的变更数据中包括所述接口参数中的各字段。4.根据权利要求3所述的方法，其特征在于，所述确认接收的所述源系统中业务数据的变更数据中包括所述接口参数中的各字段之后，包括：将接收的所述源系统中业务数据的变更数据组装为第一消息，通将所述第一消息发布到第一消息中间件；所述将所述变更数据按照预设结构写入到第一数据库，包括：响应于发布到所述第一消息中间件的所述第一消息，将所述变更数据按照预设结构写入到第一数据库。5.根据权利要求2或4所述的方法，其特征在于，所述将所述变更数据按照预设结构写入到第一数据库，包括：对所述变更数据进行数据合法性验证并确认所述数据合法性验证通过，所述数据合法性验证包括验证所述变更数据中的业务标识、数据版本号和业务变更字段；将所述变更数据按照所述第一数据库的数据存储结构进行转换并写入到所述第一数据库中。6.根据权利要求5所述的方法，其特征在于，所述将所述变更数据按照所述第一数据库的数据存储结构进行转换并写入到所述第一数据库中，包括：将所述变更数据按照所述第一数据库的数据存储结构进行转换，得到转换后的所述变更数据；获取分布式锁，并在确认所述分布式锁获取成功后，对所述变更数据进行版本判定，以确认所述变更数据为最新版本；将最新版本的转换后的所述变更数据按照对应的源系统标识写入到所述第一数据库，其中，所述源系统标识是根据所述变更数据中的所述业务变更字段确定的所述业务数据所属的源系统的标识。7.根据权利要求6所述的方法，其特征在于，所述对所述变更数据进行版本判定，以确认所述变更数据为最新版本，包括：从第二数据库中获取所述变更数据最近一次的已存版本号；2CN114860721A权利要求书2/3页将所述变更数据中的所述数据版本号与所述已存版本号进行比较，在所述变更数据中的所述数据版本号大于或等于所述已存版本号的情况下，确认所述变更数据为最新版本。8.根据权利要求7所述的方法，其特征在于，所述将最新版本的转换后的所述变更数据按照对应的源系统标识写入到所述第一数据库之后，包括：释放所述分布式锁，以及，将所述第二数据库中的所述已存版本号更新为所述变更数据中的所述数据版本号。9.根据权利要求1所述的方法，其特征在于，所述生成变更消息之后，包括：将所述变更消息发布到第二消息中间件；