(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210859994.7 (22)申请日 2022.07.22 (65)同一申请的已公布的文献号 申请公布号 CN 114936250 A (43)申请公布日 2022.08.23 (73)专利权人 浙江中控技 术股份有限公司 地址 310000 浙江省杭州市滨江区六和路 309号 (72)发明人 陈晖　周曼　汪若彪　陆卫军　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 梁韬 (51)Int.Cl. G06F 16/25(2019.01) G06F 8/36(2018.01)审查员 李文静 (54)发明名称 一种数据处 理方法、 装置、 设备及存 储介质 (57)摘要 本发明的实施例提供了一种数据处理方法、 装置、 设备及存储介质， 涉及数据处理领域， 该方 法包括： 若监测到第一组件的输出端口发送的数 据， 则根据第一组件和第二组件之间的数据连 线， 将数据发送至第二组件的输入端口， 数据连 线用于表征第一组件和第二组件之间的数据流 向； 判断第一组件的输出端口与第二组件的输入 端口之间是否存在预设的数据字段映射； 若存在 数据字段映射， 则按照数据字段映射对 数据进行 格式转换， 得到转换后的数据； 采用第二组件对 转换后的数据执行第二组件对应的处理操作。 采 用本发明， 可 以提升数据处理的效率， 解决不同 组件连接的适配问题。 权利要求书3页 说明书17页 附图6页 CN 114936250 B 2022.11.04 CN 114936250 B 1.一种数据处 理方法， 其特 征在于， 所述方法包括： 若监测到第 一组件的输出端口发送的数据， 则根据 所述第一组件和第 二组件之间的数 据连线， 将所述数据发送至所述第二组件的输入端口， 所述数据连线用于表征所述第一组 件和所述第二组件之间的数据流向； 判断所述第一组件的输出端口与所述第二组件的输入端口之间是否存在预设的数据 字段映射； 若存在所述数据字段映射， 则按照所述数据字段映射对所述数据进行格式转换， 得到 转换后的数据； 采用所述第二组件 对所述转换后的数据执 行所述第二组件 对应的处 理操作； 其中， 所述按照所述数据字段映射对所述数据进行格式转换， 得到转换后的数据， 包 括： 判断所述数据字段映射中是否存在字段 连线； 若存在所述字段连线， 则根据所述字段连线对应的数据转换方式， 对所述数据进行格 式转换， 得到第一 转换后的数据； 根据所述第 一转换后的数据， 判断所述第 二组件的输入端口的数据字段是否存在空缺 数据字段， 所述空缺数据字段为所述第一组件的输出端口的数据字段中不包含的数据字 段； 若存在所述空缺数据字段， 则根据所述数据字段映射中所述空缺数据字段的默认参 数， 对所述第一 转换后的数据进行 数据填充， 得到所述 转换后的数据； 所述判断所述第一组件的输出端口与所述第二组件的输入端口之间是否存在预设的 数据字段映射之前， 所述方法还 包括： 若监测到针对所述第 一组件的输出端口和所述第 二组件的输入端口的数据连线操作， 则判断所述第一组件的输出端口和所述第二组件的输入端口 的数据字段 是否完全一致； 若不完全一致， 则根据 所述第一组件的输出端口和所述第 二组件的输入端口的数据字 段名和数据类型， 确定连线等级； 采用所述连线等级对应的连线策略， 生成所述字段 连线； 若所述字段连线包括： 第 一类字段连线， 则根据 所述第一类字段连线， 生成所述数据字 段映射； 其中， 所述第 一类字段连线用于指示所述第 一组件的输出端口的数据字段与 所述第二 组件的输入端口 的数据字段之间进行等 价转换或无需转换便形成匹配。 2.根据权利要求1所述的方法， 其特征在于， 所述判断所述数据字段映射中是否存在字 段连线， 包括： 若不存在所述字段连线， 确定所述第二组件的输入端口的所述空缺数据字段， 根据所 述数据字段映射中空缺数据字段 的默认参数， 对所述数据进行数据填充， 得到所述转换后 的数据。 3.根据权利要求1所述的方法， 其特征在于， 所述判断所述数据字段映射中是否存在字 段连线， 还包括： 若存在所述字段 连线， 判断所述数据字段映射中是否还 存在转换脚本； 若存在所述转换脚本， 则利用所述转换脚本， 根据 所述字段连线对应的数据转换方式，权　利　要　求　书 1/3 页 2 CN 114936250 B 2对所述数据进行格式转换， 得到所述第一 转换后的数据。 4.根据权利要求1所述的方法， 其特征在于， 所述若所述字段连线包括： 第一类字段连 线， 根据所述第一类字段 连线， 生成所述数据字段映射， 包括： 若所述字段连线还包括： 第 二类字段连线， 则根据 所述第一类字段连线、 所述第 二类字 段连线以及针对所述第二类字段 连线输入的转换脚本， 生成所述数据字段映射； 其中， 所述第 二类字段连线用于指示所述第 一组件的输出端口的数据字段与 所述第二 组件的输入端口 的数据字段之间需要通过 所述转换脚本转换后才能形成匹配。 5.根据权利要求1所述的方法， 其特征在于， 所述若所述字段连线包括： 第一类字段连 线， 根据所述第一类字段 连线， 生成所述数据字段映射， 还 包括： 若所述第二组件的输入端口的数据字段存在空缺数据字段， 则根据所述第 一类字段连 线、 针对所述空缺数据字段输入的默认参数， 生成所述数据字段映射， 其中， 所述空缺数据 字段为所述第一组件的输出端口 的数据字段中不包 含的数据字段。 6.一种数据处 理装置， 其特 征在于， 所述装置包括： 发送模块， 用于若监测到第一组件的输出端口发送的数据， 则根据所述第一组件和第 二组件之间的数据连线， 将所述数据发送至所述第二组件的输入端口， 所述数据连线用于 表征所述第一组件和所述第二组件之间的数据流向； 判断模块， 用于判断所述第 一组件的输出端口与 所述第二组件的输入端口之间是否存 在预设的数据字段映射； 转换模块， 用于若存在所述数据字段映射， 则按照所述数据字段映射对所述数据进行 格式转换， 得到转换后的数据； 处理模块， 用于采用所述第 二组件对所述转换后的数据 执行所述第 二组件对应的处理 操作； 所述判断模块， 具体还用于判断所述数据字段映射中是否存在字段 连线； 所述转换模块， 具体还用于若存在所述字段连线， 则根据所述字段连线对应的数据转 换方式， 对所述数据进行格式转换， 得到第一 转换后的数据； 所述判断模块， 具体还用于根据所述第一转换后的数据， 判断所述第二组件的输入端 口的数据字段是否存在空缺数据字段， 所述空缺数据字段为所述第一组件的输出端口的数 据字段中不包 含的数据字段； 所述转换模块， 具体还用于若存在所述空缺数据字段， 则根据所述数据字段映射中所 述空缺数据字段的默认参数， 对所述第一转换后的数据进行数据填充， 得到所述转换后的 数据； 所述判断模块， 具体还用于若监测到针对所述第 一组件的输出端口和所述第 二组件的 输入端口的数据连线操作， 则判断所述第一组件的输出端口和所述第二组件的输入端口的 数据字段 是否完全一致； 所述数据处理装置还包括： 确定模块， 用于若不完全一致， 则根据 所述第一组件的输出 端口和所述第二组件的输入端口 的数据字段名和数据类型， 确定连线等级； 所述数据处理装置还包括： 生成模块， 用于采用所述连线等级对应的连线策略， 生成所 述字段连线； 所述生成模块， 具体还用于若所述字段连线包括： 第 一类字段连线， 则根据所述第一类权　利　要　求　书 2/3 页 3 CN 114936250 B 3