(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211141329.0 (22)申请日 2022.09.20 (71)申请人 数字浙江技 术运营有限公司 地址 310000 浙江省杭州市滨江区长河街 道滨兴路1866号2号楼10 01室 (72)发明人 朱骏　赵腾飞　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 张萌 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/245(2019.01) G06F 16/2457(2019.01) G06F 16/901(2019.01) G06F 16/903(2019.01)G06Q 50/26(2012.01) (54)发明名称 基于企业数据的数源转换方法、 装置、 设备 及介质 (57)摘要 本申请提供了基于企业数据的数源转换方 法、 装置、 设备及介质， 该方法在基于政府侧的各 服务系统中存储的各企业的企业数据， 获取各企 业的待处理企业数据后， 将各企业的待处理企业 数据存储在 汇总数据库中； 采用预设的数源转换 技术， 对汇总数据库存储的待处理企业数据中存 在关联关系的待处理企业数据进行处理； 将处理 后的企业数据存储在图数据库， 图数据库存储了 处理后的企业数据之间的关联关系。 该方法采用 数源转换技术实现汇总数据库中存在关联关系 的企业数据转换为图数据库可识别以图谱形式 的企业数据， 提高了企业数据查询的查询效率。 权利要求书2页 说明书11页 附图3页 CN 115470279 A 2022.12.13 CN 115470279 A 1.一种基于企业数据的数源转换 方法， 其特 征在于， 应用于服 务器中， 所述方法包括： 基于政府侧的各服务系统中存储的各企业的企业数据， 获取所述各企业的待处理企业 数据， 所述企业数据包括企业的各类业务数据和企业的基本数据； 所述待处理企业数据包 括具有时序传输关系的时序业 务数据和具有预设时间粒度的归集 业务数据； 将所述各企业的待处 理企业数据存 储在汇总数据库中； 采用预设的数源转换技术， 对所述汇总数据库存储的所述待处理企业数据中存在 关联 关系的待处 理企业数据进行处 理； 将处理后的企业数据存储在图数据库， 所述图数据库存储了所述处理后的企业数据之 间的关联关系。 2.如权利要求1所述的方法， 其特征在于， 将处理后的企业数据存储在图数据库之后， 所述方法还 包括： 获取用户的业 务查询请求； 所述 业务查询请求包括 查询内容； 若所述查询内容为查询具有非关联关系的企业数据， 则从所述汇总数据库中查询所述 查询内容对应的目标企业数据； 若所述查询内容为查询具有关联关系的企业数据， 则从所述图数据库中查询所述查询 内容对应的目标企业数据。 3.如权利要求1所述的方法， 其特征在于， 采用预设的数源转换技术， 对所述汇总数据 库存储的所述待处 理企业数据中存在关联关系的待处 理企业数据进行处 理， 包括： 采用配置的定量取值方式， 通过游标方式， 按照数据顺序， 获取所述汇总数据库存储的 所述待处 理企业数据中目标 数量的存在关联关系的待处 理企业数据； 基于所述服务器 中CPU核数， 采用配置的数据流分批方式， 对所述目标数量的存在关联 关系的待处理企业数据中待处理企业数据进行分批处理， 得到与所述CPU核数相等的待处 理数据组， 每两个待处 理数据组的数据处 理时长不大于预设时长阈值； 针对每个待处理数据组， 基于预设的数据类型与目标存储字段的处理映射表， 对所述 待处理数据 组中的待处理企业数据进行字段处理， 得到字段处理后的待处理企业数据； 以 及， 将所述待处理数据组中字段 处理后的待处理企业数据和未进 行字段处理的待处理企业 数据的数据格式进行转换， 得到所述待处理数据组对应的满足所述图数据库存储格式的待 处理企业数据。 4.如权利要求3所述的方法， 其特征在于， 采用配置的定量取值方式， 获取所述汇总数 据库存储的所述待处 理企业数据中存在关联关系的待处 理企业数据， 包括： 计算所述汇总数据库存储的所述待处理企业数据中存在关联关系的各数据类型的待 处理企业数据对应的所需运行内存量； 对所述各数据类型的待处理企业数据对应的所需运行内存量进行算数平均运算， 得到 所述各数据类型对应的平均运行内存量； 基于所述平均运行内存量、 所述CPU核数、 所述服务器运行的最大内存和预设的内存需 求比例， 确定获取存在关联关系的待处 理企业数据的目标 数量。 5.如权利要求3所述的方法， 其特征在于， 基于所述服务器中CPU核数， 采用配置的数据 流分批方式， 对所述存在关联关系的待处理企业数据中各数据类型的待处理企业数据进 行 分批处理， 得到与所述CPU 核数相等的待处 理数据组， 包括：权　利　要　求　书 1/2 页 2 CN 115470279 A 2计算各类型 数据的待处 理企业数据对应的所需处 理时长； 对所述各类型数据的待处理企业数据对应的所需处理时长进行算数平均运算， 得到所 述各数据类型对应的平均处 理时长； 基于所述平均处理时长和所述各类型数据的待处理企业数据的总数， 得到所述各类型 数据的总处 理时长； 基于所述服务器 中CPU核数， 对所述各类型数据的总处理时长进行分批处理， 得到与所 述CPU核数相等的待处理数据 组， 每个待处理数据 组包括不同总处理时长对应的待处理企 业数据； 每两个待处 理数据组间的数据处 理时长差不大于预设时长阈值。 6.如权利要求1所述的方法， 其特征在于， 将所述各企业的待处理企业数据存储在汇总 数据库中之后， 所述方法还 包括： 实时对所述汇总数据库中存 储的各企业的企业数据进行 更新检测； 若存储的各企业的企业数据存在更新的数据， 则执行： 采用预设的数源转换技术， 对所 述汇总数据库存 储的所述待处 理企业数据中存在关联关系的待处 理企业数据进行处 理。 7.如权利要求1所述的方法， 其特征在于， 所述存在 关联关系的待处理企业数据包括层 级关联的待处 理企业数据和/或统计关联的待处 理企业数据。 8.一种基于企业数据的数源转换装置， 其特 征在于， 应用于服 务器中， 所述装置包括： 获取单元， 用于基于政府侧的各服务系统中存储的各企业的企业数据， 获取所述各企 业的待处理企业数据， 所述企业数据包括企业的各类业务数据和企业的基本数据； 所述待 处理企业数据包括具有时序传输关系的时序业务数据和具有预设时间粒度的归集业务数 据； 存储单元， 用于将所述各企业的待处 理企业数据存 储在汇总数据库中； 处理单元， 用于采用预设的数源转换技术， 对所述汇总数据库存储的所述待处理企业 数据中存在关联关系的待处 理企业数据进行处 理； 所述存储单元， 还用于将处理后的企业数据存储在图数据库， 所述图数据库存储了所 述处理后的企业数据之间的关联关系。 9.一种基于企业数据的数源转换设备， 其特征在于， 所述设备包括处理器、 通信接口、 存储器和通信总线， 其中， 处 理器， 通信接口， 存 储器通过通信总线完成相互间的通信； 存储器， 用于存放计算机程序； 处理器， 用于执 行存储器上所存储的程序时， 实现权利要求1 ‑7任一所述的方法步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质内存储有计算机 程序， 所述计算机程序被处 理器执行时实现权利要求1 ‑7任一所述的方法步骤。权　利　要　求　书 2/2 页 3 CN 115470279 A 3