(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210381940.4 (22)申请日 2022.04.12 (71)申请人 树根互联股份有限公司 地址 510000 广东省广州市海珠区华洲路 190号5栋整栋1- 3层 (72)发明人 谭启超　张健文　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 姚大雷 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/25(2019.01) G06F 16/28(2019.01) (54)发明名称 一种数据订阅方法、 装置及代理订阅设备 (57)摘要 本申请提供一种数据订阅方法、 装置及代理 订阅设备。 该方法包括： 监听源数据设备对应的 各源数据主题是否更新； 获取各源 数据主题对应 的增量数据； 将增量数据进行预设类型的数据处 理， 得到业务数据主题对应的业务数据， 其中， 预 设类型的数据处理包括整合、 分解和转化， 各业 务数据主题与至少一个源数据主题关联； 根据各 用户端设备发送的业务数据获取请求， 以及业务 数据主题与各用户端设备之间的预设订阅关系， 将业务数据发送至对应的用户端设备。 本申请通 过代理订阅设备将源数据主题对应的增量数据 处理为用户端设备能够接收的业务数据， 解除了 数据源与用户侧之间的业务耦合， 降低了数据源 与用户侧的对接成本 。 权利要求书2页 说明书8页 附图1页 CN 114676153 A 2022.06.28 CN 114676153 A 1.一种数据订阅方法， 其特征在于， 应用于代理订 阅设备， 所述代理订 阅设备连接源数 据设备和至少一个用户端设备， 所述数据订阅方法包括： 监听所述源数据设备对应的各源数据主题是否更新； 获取各源数据主题对应的增量数据； 将所述增量数据进行预设类型的数据处理， 得到业务数据主题对应的业务数据， 其中， 所述预设类型 的数据处理包括整合、 分解和转化， 各业务数据主题与至少一个源数据主题 关联； 根据各用户端设备发送的业务数据获取请求， 以及所述业务数据主题与各所述用户端 设备之间的预设订阅关系， 将所述 业务数据发送至对应的用户端设备。 2.根据权利要求1所述的数据订阅方法， 其特征在于， 所述预设类型的数据处理为整 合， 将所述增量数据进 行预设类型的数据处理， 得到业务数据主题对应的业务数据的步骤， 包括： 若业务数据主题与至少两个源数据主题关联， 将各所述源数据主题对应的第 一元数据 进行合并， 得到所述 业务数据主题对应的第二元 数据； 其中， 所述第一元数据用于指示源数据主题对应的源数据的存储区域， 所述第二元数 据对应的全部源数据为所述 业务数据主题对应的业 务数据。 3.根据权利要求1所述的数据订阅方法， 其特征在于， 所述预设类型的数据处理为转 换， 将所述增量数据进 行预设类型的数据处理， 得到业务数据主题对应的业务数据的步骤， 包括： 根据预设的第 一字段与第 二字段之间的第 一映射关系， 通过字段映射将所述增量数据 中的第一字段转换为对应的第二字段， 得到业 务数据主题对应的业 务数据。 4.根据权利要求1所述的数据订阅方法， 其特征在于， 所述预设订阅关系的创建步骤， 包括： 接收用户端设备发送的订阅请求， 其中， 所述订阅请求包括需要订阅的业务数据主题 以及所述用户端设备对应的设备 标识； 根据所述订阅请求创建所述预设订阅关系， 其中， 所述预设订阅关系包括所述设备标 识与需要订阅的所述 业务数据主题之间的第二映射关系。 5.根据权利要求4所述的数据订 阅方法， 其特征在于， 根据 各用户端设备发送的业务数 据获取请求， 以及所述业务数据主题与各所述用户端设备之间的预设订阅关系， 将所述业 务数据发送至对应的所述用户端设备的步骤， 包括： 判断所述 业务数据主题对应的所述用户端设备 是否为免检设备； 若所述业务数据主题对应的所述用户端设备不是免检设备， 对所述用户端设备发送的 业务数据获取请求进 行校验， 所述业务数据获取请求包括设备标识以及发送所述业务数据 获取请求对应的请求时间戳； 若校验成功， 将所述业务数据主题对应的所述业务数据发送至所述设备标识对应的所 述用户端设备。 6.根据权利要求5所述的数据订 阅方法， 其特征在于， 所述预设订 阅关系包括订阅授权 时间区间， 对所述用户端设备发送的业 务数据获取请求进行 校验的步骤， 包括： 若所述业务数据获取请求中的设备标识与 所述预设订阅关系中的设备标识相同， 判断权　利　要　求　书 1/2 页 2 CN 114676153 A 2所述请求时间戳是否处于所述 订阅授权时间区间内； 若所述请求时间戳处于所述 订阅授权时间区间内， 判定校验成功； 若所述请求时间戳 不处于所述 订阅授权时间区间内， 判定校验失败。 7.一种数据订阅装置， 其特征在于， 应用于代理订 阅设备， 所述代理订 阅设备连接源数 据设备和至少一个用户端设备， 所述数据订阅装置包括： 监听模块,用于监听所述源数据设备对应的各源数据主题是否更新； 获取模块,用于获取 各源数据主题对应的增量数据； 处理模块,用于将所述增量数据进行预设类型的数据处理， 得到业务数据主题对应的 业务数据， 其中， 所述预设类型的数据 处理包括整合、 分解和转化， 各业务数据主题与至少 一个源数据主题关联； 发送模块,用于根据各所述用户端设备发送的业务数据获取请求， 以及所述业务数据 主题与各所述用户端设备之 间的预设订阅关系， 将所述业务数据发送至对应的所述用户端 设备。 8.根据权利要求7所述的数据订阅装置， 其特征在于， 所述预设类型的数据处理为整 合， 所述处 理模块具体 应用于： 若业务数据主题与至少两个源数据主题关联， 将各所述源数据主题对应的第 一元数据 进行合并， 得到所述 业务数据主题对应的第二元 数据； 其中， 所述第一元数据用于指示源数据主题对应的源数据的存储区域， 所述第二元数 据对应的全部源数据为所述 业务数据主题对应的业 务数据。 9.一种代 理订阅设备， 其特征在于， 所述代 理订阅设备包括处理器和存储器， 所述存储 器存储有计算机程序， 所述计算机程序在所述处理器上执行时实现权利要求 1至6中任一项 所述的数据订阅方法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机程 序， 所述计算机程序在处 理器上执行时实现权利要求1至 6中任一项所述的数据订阅方法。权　利　要　求　书 2/2 页 3 CN 114676153 A 3