(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211074164.X (22)申请日 2022.09.02 (71)申请人 杭州数梦 工场科技有限公司 地址 310024 浙江省杭州市转塘科技经济 区块16号 4幢326室 (72)发明人 张俊鹏　崔晓峰　周文明　 (74)专利代理 机构 北京博思佳知识产权代理有 限公司 1 1415 专利代理师 李威 (51)Int.Cl. G06F 9/445(2018.01) G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 接口服务编排与数据处 理的方法及装置 (57)摘要 本申请提供一种接口服务编排与数据处理 的方法及装置。 其中， 所述接口服务编排方法包 括接收接口服务编排请求； 所述服务编排请求包 括接口服务编排配置文件； 响应于所述接口服务 编排请求， 从所述接口服务编排请求中获取所述 接口服务编排配置文件； 根据所述接口服务编排 配置文件生成Fl ink实例。 权利要求书3页 说明书18页 附图10页 CN 115480839 A 2022.12.16 CN 115480839 A 1.一种接口服 务编排方法， 其特 征在于， 所述方法包括： 接收接口服 务编排请求； 所述 服务编排请求包括接口服 务编排配置文件； 响应于所述接口服务编 排请求， 从所述接口服务编 排请求中获取所述接口服务编排配 置文件； 根据所述接口服 务编排配置文件生成Fl ink实例。 2.根据权利 要求1所述的方法， 其特征在于， 所述Flink实例包括常驻实例； 所述常驻实 例包括若干第一source算子和第一map算子； 所述根据所述接口服 务编排配置文件生成Fl ink实例， 包括： 根据所述接口服 务编排配置文件， 将所述第一map算子对接口 的访问顺序进行编排； 将至少一个所述第一source算子与至少一个所述第一map算子组合生成所述常驻实 例。 3.根据权利要求1所述的方法， 其特征在于， 所述接口服务编排配置文件包含多个API 及其访问顺序的信息， 所述Flink实例包括独占实例； 所述独占实例包括若干由第二source 算子和第二map算子组成的算子链； 所述根据所述接口服 务编排配置文件生成Fl ink实例， 包括： 根据所述多个API及其访问顺序的信息， 生成动态服 务编排的算子链； 基于生成的所述动态服 务编排的算子链生成所述独占实例。 4.根据权利要求3所述的方法， 其特征在于， 所述根据所述多个API及其访 问顺序的信 息， 生成动态服 务编排的算子链， 包括： 根据所述接口服务编排配置文件包含的多个API及其访问顺序的信息， 将所述第二 source算子进行配置， 以对应于唯一位于第一访问顺序的API； 或者， 若存在至少两个API位 于所述第一访问顺序， 则将所述第二source算子进行配置， 以对应于所述至少两个API中的 任一API； 将所述第二map算子进行配置， 以与剩余API相对应； 根据所述多个API的所述访问顺序的信息， 对完成配置的所述第二source算子和所述 第二map算子进 行排列， 以根据所述访问顺序完成对接口的访问， 生成动态 服务编排的算子 链。 5.一种数据处理方法， 其特征在于， 所述方法基于权利要求1 ‑4中任一所述的接口服务 编排方法生成的Fl ink实例实现； 所述方法包括： 接收处理请求方发起的处理请求， 并从所述处理请求中获取请求参数和所述接口服务 编排配置文件； 响应于所述处理请求运行所述Flink实例， 以使所述Flink实例基于所述请求参数和所 述接口服 务编排配置文件获得综合处 理结果； 将所述Fl ink实例生成的所述综合处 理结果返回所述处 理请求方。 6.根据权利要求5所述的方法， 其特征在于， 所述基于所述请求参数和所述接口服务编 排配置文件获得综合处 理结果， 包括： 若存在至少两个API以所述请求参数作为处理入参， 则在所述至少两个API中选取任一 API， 并将所述请求 参数输入所述任一API， 得到相应的单点处 理结果； 将所述单点处理结果中包含的值与 所述请求参数共同作为处理入参， 对所述至少两个权　利　要　求　书 1/3 页 2 CN 115480839 A 2API中的其 他API进行处 理； 对所述多个API分别处 理得到的处 理结果进行整合， 得到所述综合处 理结果。 7.根据权利要求5所述的方法， 其特征在于， 所述Flink实例中含有用于对所述请求参 数和所述接口服 务编排配置文件进行处 理的任务处 理算子； 在所述Flink实例为常驻实例的情况下， 所述常驻实例中运行有预设的固定服务编排 的算子； 或者， 在所述Flink实例为针对所述处理请求生成的独占实例的情况下， 所述独占实例中运 行有针对所述处 理请求生成的所述动态服 务编排的算子链。 8.根据权利要求7所述的方法， 其特征在于， 所述常驻实例包括若干第一source算子、 第一map算子； 所述第一map算子包含一个预设的服务编排， 所述Flink 实例基于所述请求参 数和所述接口服 务编排配置文件获得综合处 理结果， 包括： 所述第一source算子 接收所述处 理请求， 并分配至所述第一map算子； 所述第一map算子根据所述处理请求获得所述接口服务编排配置文件， 运行对应的预 设的固定服 务编排， 获得 所述综合处 理结果。 9.根据权利要求7所述的方法， 其特征在于， 所述算子链包括： 与所述多个API一一对应 的算子， 每个算子用于实现相应API对应的处理操作， 且 各算子之间按照所述访问顺序对自 身生成的处 理结果进行相互传递； 其中， 所述 算子链中的算子包括： 所述第二source算子， 对应于所述多个API中唯一以所述请求参数为处理入参的API； 或者， 若存在至少两个API以所述请求参数作为处理入参， 则所述第二source算子对应于所 述至少两个API中的任一API； 所述第二map算子， 与剩余API相对应。 10.根据权利要求9所述的方法， 所述Flink实例基于所述请求参数和所述接口服务编 排配置文件获得综合处 理结果， 包括： 所述第二source算子接收所述处理请求， 并实现所述第二source算子对应 的API的处 理操作， 获得 数据流； 根据所述多个API及其访问顺序的信息， 所述数据流依次经 过各第二map算子； 所述第二map算子根据接收的数据流， 实现相应API对应的处理操作后， 将处理结果汇 入所述接收的数据流， 传输给 下一个map算子； 所有第二map算子 完成处理操作后， 在最终形成的数据流中选取 所述综合处 理结果。 11.根据权利要求5所述的方法， 其特征在于， 所述将所述综合处理结果返回给所述处 理请求方， 包括： 将所述综合处理结果通过所述处理请求方发起所述处理请求的API返回给所述处理请 求方； 或者， 将所述综合处理结果发送到与所述处理请求方之间建立的websocket长链接， 并通过 所述websocket长链接将所述综合处 理结果推送至所述处 理请求方。 12.根据权利要求5所述的方法， 其特征在于， 所述Flink实例中包含多个source算子， 还运行有用于分配所述请求 参数的数据分配服 务， 通过该数据分配服 务实现下述操作： 将所述处 理请求中的任一数据段分配至任一source算子； 在确定所述任一source算子针对所述任一数据段执行checkpoint  commit函数的情况权　利　要　求　书 2/3 页 3 CN 115480839 A 3