数据处理方法及数据处理系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113923258A(43)申请公布日2022.01.11(21)申请号202111513661.0(22)申请日2021.12.13(71)申请人北京九章云极科技有限公司地址100083北京市海淀区王庄路1号清华同方科技广场B座28层(72)发明人吴晨路明奎方磊(74)专利代理机构北京银龙知识产权代理有限公司11243代理人黄灿(51)Int.Cl.H04L67/565(2022.01)权利要求书2页说明书13页附图3页(54)发明名称数据处理方法及数据处理系统(57)摘要本发明提供了一种数据处理方法及数据处理系统，该方法应用于数据处理系统，数据处理系统包括至少两个工作节点，该方法包括：获取第一工作节点的响应数据格式，以及第二工作节点的输出数据格式；将输出数据格式与响应数据格式进行匹配，确定目标数据格式；基于目标数据格式传输数据。本发明实施例中，数据处理系统中的各个工作节点在进行数据传输之前，先基于本发明提供的通讯机制确定工作节点之间的支持的数据格式，从而确定出相邻工作节点均支持的目标数据格式，如此一来，在进行数据传输时，将数据转换为目标数据格式进行传输，从而在一定程度上减少因各个工作节点数据格式不匹配造成的数据处理失败，进而提高了数据处理的效率。CN113923258ACN113923258A权利要求书1/2页1.一种数据处理方法，其特征在于，应用于数据处理系统，所述数据处理系统包括至少两个工作节点，所述方法包括：获取第一工作节点的响应数据格式，以及第二工作节点的输出数据格式；将所述输出数据格式与所述响应数据格式进行匹配，确定目标数据格式；基于所述目标数据格式传输数据。2.根据权利要求1所述的方法，其特征在于，所述将所述输出数据格式与所述响应数据格式进行匹配，确定目标数据格式包括：确定与所述响应数据格式相匹配的输出数据格式；从所述相匹配的输出数据格式中确定所述目标数据格式。3.根据权利要求2所述的方法，其特征在于，所述从所述相匹配的输出数据格式中确定所述目标数据格式包括：获取显示数据配置；从所述相匹配的输出数据格式中选择出满足所述显示数据配置的数据格式，作为所述目标数据格式。4.根据权利要求2所述的方法，其特征在于，所述从所述相匹配的输出数据格式中确定所述目标数据格式包括：根据待处理数据量和/或响应时间配置，从所述相匹配的输出数据格式中确定所述目标数据格式。5.根据权利要求1‑4中任一项所述的方法，其特征在于，所述方法包括：响应所述第一工作节点接收到的服务请求，所述服务请求包括待处理数据以及要求反馈的数据格式；将所述服务请求包含的要求反馈的数据格式确定为所述第一工作节点的响应数据格式。6.根据权利要求5所述的方法，其特征在于，所述数据处理系统还包括中间节点，所述基于所述目标数据格式传输数据之前，所述方法还包括：将所述第二工作节点的响应数据格式发送至所述中间节点；将所述中间节点的输出数据格式与所述第二工作节点的响应数据格式进行匹配，确定所述中间节点与所述第二工作节点进行通信的第一中间数据格式；将所述中间节点的响应数据格式发送至所述第一工作节点；将所述第一工作节点的输出数据格式与所述中间节点的响应数据格式进行匹配，确定所述中间节点与所述第一工作节点进行通信的第二中间数据格式。7.根据权利要求6所述的方法，其特征在于，所述基于所述目标数据格式传输数据包括：将所述第一工作节点中的待处理数据以所述第二中间数据格式将数据传输至所述中间节点；控制所述中间节点以所述第一中间数据格式将数据传输至所述第二工作节点；控制所述第二工作节点以所述目标数据格式将数据传输至所述第一工作节点。8.根据权利要求1所述的方法，其特征在于，所述将所述输出数据格式与所述响应数据格式进行匹配之后，所述方法还包括：2CN113923258A权利要求书2/2页在所述输出数据格式与所述响应数据格式不匹配的情况下，发送报错信息。9.根据权利要求1所述的方法，其特征在于，所述方法还包括：获取当前工作节点兼容的数据格式；根据所述当前工作节点兼容的数据格式，以及待扩展数据格式，确定所述待扩展数据格式与所述当前工作节点兼容的数据格式的转换方式；根据所述转换方式，更新所述当前工作节点。10.根据权利要求1所述的方法，其特征在于，所述方法还包括：在所述数据处理系统新增工作节点的情况下，确定新增工作节点对应的上游工作节点和下游工作节点；将所述新增工作节点的响应数据格式确定为所述上游工作节点对应的输出数据格式，将所述新增工作节点的输出数据格式确定为所述下游工作节点对应的响应数据格式。11.一种数据处理系统，其特征在于，所述数据处理系统包括至少两个工作节点，所述系统包括：第一获取模块，用于获取第一工作节点的响应数