(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211289521.4 (22)申请日 2022.10.20 (71)申请人 中国农业银行股份有限公司 地址 100005 北京市东城区建国门内大街 69号 (72)发明人 杨楠　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 曹伟 (51)Int.Cl. G06F 16/951(2019.01) G06F 16/907(2019.01) G06F 16/23(2019.01) G06F 9/54(2006.01) (54)发明名称 一种元数据捕获方法、 装置、 系统和介质 (57)摘要 本申请提供一种元数据捕获方法、 装置、 系 统和介质， 该方法包括： 控制简单存储服务向分 布式消息队列发送请求信息； 当分布式消息队列 返回请求信息对应的响应信息时， 则控制分布式 消息队列存储简单存储服务发送的元数据信息 流； 控制分布式消息队列向数据治理系统发送元 数据信息流； 当数据治理系统写入 元数据信息流 后， 返回写入完成信息。 从而可 以实现元数据信 息的自动化采集捕获， 并在数据治理系统写入元 数据信息流后， 返回写入完成信息， 可 以防止元 数据信息的丢失， 提升元数据信息传递的可靠 性。 权利要求书1页 说明书6页 附图2页 CN 115455267 A 2022.12.09 CN 115455267 A 1.一种元 数据捕获方法， 其特 征在于， 包括： 控制简单存 储服务向分布式消息队列发送请求信息； 当所述分布式消息队列返回所述请求信 息对应的响应信 息时， 则控制所述分布式消息 队列存储所述简单存 储服务发送的元 数据信息流； 控制所述分布式消息队列向数据治理系统发送所述元 数据信息流； 当所述数据治理系统写入所述元 数据信息流后， 返回写入完成信息 。 2.根据权利要求1所述的方法， 其特征在于， 在所述简单存储服务发送所述元数据信 息 流之前， 还 包括: 将所述元 数据信息流的信息版本号注入所述元 数据信息流。 3.根据权利要求2所述的方法， 其特征在于， 在所述数据治理系统写入所述元数据信 息 流之前， 还 包括： 判断所述数据治理系统中是否存在与所述元数据信息流的信息版本号一致的版本号 元数据； 若存在， 则拒绝所述元 数据信息流写入所述数据治理系统。 4.根据权利要求1所述的方法， 其特 征在于， 所述元 数据信息流， 包括： 数据更新、 创建和/或删除信息 。 5.一种元 数据捕获装置， 其特 征在于， 包括： 请求单元， 用于控制简单存 储服务向分布式消息队列发送请求信息； 存储单元， 用于当所述分布式消息队列返回所述请求信息对应的响应信息时， 存则储 控制所述分布式消息队列存 储所述简单存 储服务发送的元 数据信息流； 单 元 发送单元， 用于控制所述分布式消息队列向数据治理系统发送所述元 数据信息流； 写入单元， 用于当所述数据治理系统写入所述元 数据信息流后， 返回写入完成信息 。 6.根据权利要求5所述的装置， 其特 征在于， 还 包括： 注入单元， 用于将所述元 数据信息流的信息版本号注入所述元 数据信息流。 7.根据权利要求6所述的装置， 其特 征在于， 还 包括： 判断单元， 用于判断所述数据治理系统中是否存在与 所述元数据信 息流的信 息版本号 一致的版本号元 数据； 拒绝单元， 用于当所述数据治理系统中存在与 所述元数据信 息流的信 息版本号一致的 版本号元 数据时， 则拒绝所述元 数据信息流写入所述数据治理系统。 8.根据权利要求5所述的装置， 其特 征在于， 所述元 数据信息流， 包括： 数据更新、 创建和或删除信息 。 9.一种元 数据捕获系统， 其特 征在于， 包括： 存储器， 用于存 储计算机程序； 处理器， 用于执行所述计算机程序时实现如权利要求1 ‑4任意一项所述元数据捕获方 法的步骤。 10.一种计算机可读介质， 其特征在于， 所述计算机可读介质上存储有计算机程序， 所 述计算机程序被处 理执行时实现如权利要求1 ‑4任意一项所述元 数据捕获方法的步骤。权　利　要　求　书 1/1 页 2 CN 115455267 A 2一种元数据捕获方 法、 装置、 系统和介质 技术领域 [0001]本申请涉及计算机技 术领域， 特别涉及一种元 数据捕获方法、 装置、 系统和介质。 背景技术 [0002]元数据(Metadata)， 又称中介数据、 中继数据， 为描述数据的数据(data  about  data)， 主要是描述数据属性(pr operty)的信息， 用来支持如指示存储位置、 历史数据、 资源 查找和文件记录等功能。 [0003]在进行元数据治理的过程中， 数据的实时性非常重要。 传统的方式是通过类似爬 虫的方式定时主动爬取 元数据信息， 需要人工手动操作， 无法满足 实时性要求。 发明内容 [0004]有鉴于此， 本申请的目的在于提供一种元数据捕获方法、 装置、 系统和介质， 可以 实现元数据信息的自动化采集捕获， 有效防止元数据信息的丢失， 提升元数据信息传递的 可靠性。 [0005]为实现上述目的， 本申请有如下技 术方案： [0006]第一方面， 本申请实施例提供了一种元 数据捕获方法， 包括： [0007]控制简单存 储服务向分布式消息队列发送请求信息； [0008]当所述分布式消息队列返回所述请求信息对应的响应信息时， 则控制所述分布式 消息队列存 储所述简单存 储服务发送的元 数据信息流； [0009]控制所述分布式消息队列向数据治理系统发送所述元 数据信息流； [0010]当所述数据治理系统写入所述元 数据信息流后， 返回写入完成信息 。 [0011]在一种可能的实现方式中， 在所述简单存储服务发送所述元数据信息流之前， 还 包括: [0012]将所述元 数据信息流的信息版本号注入所述元 数据信息流。 [0013]在一种可能的实现方式中， 在所述数据治理系统写入所述元数据信息流之前， 还 包括： [0014]判断所述数据治理系统中是否存在与所述元数据信息流的信息版本号一致的版 本号元数据； [0015]若存在， 则拒绝所述元 数据信息流写入所述数据治理系统。 [0016]在一种可能的实现方式 中， 所述元 数据信息流， 包括： [0017]数据更新、 创建和或删除信息 。 [0018]第二方面， 本申请实施例提供了一种元 数据捕获装置， 包括： [0019]请求单元， 用于控制简单存 储服务向分布式消息队列发送请求信息； [0020]存储单元， 用于当所述分布式消息队列返回所述请求信息对应 的响应信息时， 则 控制所述分布式消息队列存 储所述简单存 储服务发送的元 数据信息流； [0021]发送单元， 用于控制所述分布式消息队列向数据治理系统发送所述元数据信息说　明　书 1/6 页 3 CN 115455267 A 3