1.本发明涉及数据处理技术领域,尤其涉及一种应用集成方法、装置、电子设备和存储介质。
背景技术:
2.随着企业数字化建设的不断发展,企业的业务系统可以包括研、产、供、销、管等各类应用系统。而企业在向数字化转型的过程中会面临诸多难题,例如,数据格式多样化导致难以传输和集成,以及缺少与合作伙伴分享数据和后端服务的便捷途径。因此,需要对各类应用系统进行集成,实现跨系统之间的互通集成和管控。
3.目前,大多通过代码进行应用集成。然而,代码的学习十分复杂,且大多不相同,需要花费大量时间进行学习,才能基于各种代码实现应用集成。因此,对于企业来说,通过代码进行应用集成的门槛过高,进而导致集成效率低,且集成成本高。
技术实现要素:
4.本发明旨在至少解决现有技术中存在的技术问题之一。为此,本发明提出一种应用集成方法,可以通过可视化图形界面的方式进行
连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。
5.本发明还提供一种应用集成装置、电子设备和存储介质。
6.根据本发明第一方面实施例的应用集成方法,包括:确定待配置连接器,以及
所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置
指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。
7.根据本发明实施例的应用集成方法,通过获取作用于待配置连接器的连接器配置界面上的配置指令,并执行该配置指令,以对待配置连接器进行配置,无需通过代码即可完成连接器的配置,进而基于配置后的待配置连接器,实现应用集成,即通过可视化图形界面的方式进行连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。
8.根据本发明的一个实施例,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定集成后的目标数据源,以及所述目标数据源对应的数据更新配置界面;获取作用于所述数据更新配置界面的数据更新指令,并执行所述数据更新指令,以对所述目标数据源的数据结构和数据内容进行更新。
9.根据本发明的一个实施例,所述基于配置后的待配置连接器,对待集成应用进行
集成处理,之后还包括:基于集成后的集成目标,确定可编排
组件;获取作用于应用编排界面的编排指令,执行所述编排指令对应的操作,以基于所述可编排组件进行应用编排流程图绘制;基于各编排指令确定的应用编排流程图,确定编排后的编排应用;其中,所述各编排指令包括组件操作指令,所述组件操作指令用于指示待操作组件,以及用于指示对所述待操作组件进行操作的操作内容。
10.根据本发明的一个实施例,所述编排指令为所述组件操作指令的组件参数配置指令;所述执行所述编排指令对应的操作,包括:确定所述组件参数配置指令指示的待配置组件,以及所述待配置组件的配置参数;基于所述配置参数,对所述待配置组件进行参数配置。
11.根据本发明的一个实施例,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定待执行任务;获取作用于任务调度配置界面的调度配置指令,并执行所述调度配置指令,以对所述待执行任务进行配置。
12.根据本发明的一个实施例,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定集成后的目标数据源,以及所述目标数据源对应的数据查询参数设定界面;获取作用于所述数据查询参数设定界面的参数设定指令;基于所述参数设定指令,确定数据库查询语言语句,所述数据库查询语言语句用于查询所述目标数据源中的数据。
13.根据本发明的一个实施例,所述待配置连接器包括服务连接器、数据连接器、消息连接器中的至少一种;所述服务连接器用于对待集成服务进行集成处理;所述数据连接器用于对待集成数据源进行集成处理;所述消息连接器用于消费消息,以及生产消息。
14.根据本发明第二方面实施例的应用集成装置,包括:确定模块,用于确定待配置连接器,以及所述待配置连接器的连接器配置界面;执行模块,用于获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;处理模块,用于基于配置后的待配置连接器,对待集成应用进行集成处理。
15.根据本发明第三方面实施例的电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现如上述任一种所述应用集成方法。
16.根据本发明第四方面实施例的非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现如上述任一种所述应用集成方法。
17.本发明实施例中的上述一个或多个技术方案,至少具有如下技术效果之一:通过获取作用于待配置连接器的连接器配置界面上的配置指令,并执行该配置指令,以对待配置连接器进行配置,无需通过代码即可完成连接器的配置,进而基于配置后的待配置连接器,实现应用集成,即通过可视化图形界面的方式进行连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。
18.本发明的附加方面和优点将在下面的描述中部分给出,部分将从下面的描述中变得明显,或通过本发明的实践了解到。
附图说明
19.为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。
20.图1是本发明实施例提供的应用集成方法的流程示意图之一;图2是本发明实施例提供的应用集成方法的流程示意图之二;图3是本发明实施例提供的应用集成方法的流程示意图之三;图4是本发明实施例提供的应用集成装置的结构示意图;图5是本发明实施例提供的电子设备的结构示意图。
具体实施方式
21.为使本发明的目的、技术方案和优点更加清楚,下面将结合本发明中的附图,对本发明中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。
22.本发明提出以下各实施例。下面结合附图描述本发明实施例提供的应用集成方法。该应用集成方法的执行主体可以为应用集成平台,或者为服务器,或者还可以为台式电脑、笔记本电脑等,或者还可以为用户的终端,包括但不限于手机、平板电脑、pc端、车载终端以及家用智能电器等。
23.在一实施例中,应用集成平台可以为ipaas(integration platform as a service,集成平台即服务)平台。ipaas平台提供平台化的应用集成、服务开放和api管理能力,帮助企业打通、整合内外新旧业务系统和能力开放等,实现跨系统之间的互通集成和管控,具有多服务协议适配和开放管控能力,可以实现跨协议的服务能力互通,主要针对应用系统能力对外开放、api管理和系统互相访问的场景,提供统一的安全授权、流量限制等管理和控制。
24.图1是本发明实施例提供的应用集成方法的流程示意图之一,如图1所示,该应用集成方法包括:步骤110,确定待配置连接器,以及所述待配置连接器的连接器配置界面。
25.此处,待配置连接器用于实现应用集成,即将待集成应用进行集成处理。具体的,待配置连接器可以用于实现服务、数据、消息、通信协议等待集成目标的集成,进而完成应用集成。
26.该待配置连接器可以包括但不限于以下至少一种:服务连接器、数据连接器、消息连接器、应用连接器、通信协议连接器等等。
27.其中,服务连接器用于对待集成服务进行集成处理,基于此,可无缝与企业原有的微服务框架进行集成,兼容nacos、zk、eureka、consul等多种服务注册中心,提供api网关的全量管控api。此外,实现企业已有restapi、soap、dubbo、springcloud、rfc等接口的注册、协议转换和零代码服务调用。
28.其中,数据连接器用于对待集成数据源进行集成处理,基于此,可快速链接各种数据源。该数据源可以包括但不限于:mysql、oracle、sqlserver等。此外,通过对数据源的链接可快速发布数据类api接口服务。进一步地,通过数据库相关信息的注册,包括连接池的相关信息的配置,完成数据源的统一管理和使用。
29.其中,消息链接用于消费消息,以及生产消息,基于此,可以快速实现多种mq(kafka、rabbitmq、rocketmq、activemq、mqtt)消息的统一消费和管理。进一步地,通过消息总线mq可以统一消费消息并自动分发给业务编排流程;通过mq把原来同步调用的api实现异步调用,把不同生产以及消费速率不一样的api进行流量的削峰,通过mq可增强应用集成的稳定性和可靠性。此外,可以快速实现mq消息的生产,多种mq无需代码即可一键发布成为restful api,通过api即可实现mq与其他业务系统的打通。换言之,可以对接各种消息中间件,无需编码即可快速收发消息。
30.其中,应用连接器用于对待集成业务系统进行封装,基于此,可以封装业务系统的交互协议、鉴权方式和具体的系统功能,且可以零成本调用业务系统对外接口能力,无需理解与业务无关的对接内容。
31.其中,通信协议连接器,用于提供业界主流的通信协议,例如服务连接器就支持http、dubbo、webservice、springcloud等协议,数据连接器支持mysql、oracle等协议,消息连接器支持kafka、rocketmq等协议。
32.此处,连接器配置界面为对待配置连接器进行配置的界面,其用于供用户基于该连接器配置界面进行连接器的配置,具体地,其用于供用户在该连接器配置界面上触发配置指令。
33.该服务连接器的连接器配置界面包括服务配置字段,该服务配置字段可以包括但不限于以下至少一种:服务类型、应用名、服务名、版本、分组、注册中心类型、注册中心地址、描述等等。进一步地,服务类型、应用名、服务名、注册中心类型、注册中心地址为必填字段,即必配置字段。
34.该数据连接器的连接器配置界面包括数据配置字段,该数据配置字段可以包括但不限于以下至少一种:数据库编码、数据库名称、数据库类型、服务器地址、用户名、密码、状态、描述等等。进一步地,数据库名称、数据库类型、服务器地址、用户名、密码、状态为必填字段,即必配置字段。
35.该消息连接器的连接器配置界面包括消息配置字段,该消息配置字段可以包括但不限于以下至少一种:消息名称、消息类型、消息服务器地址等等。进一步地,消息名称、消
息类型、消息服务器地址为必填字段,即必配置字段。
36.步骤120,获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置。
37.此处,配置指令是响应于用户通过本发明实施例的应用设备的配置操作,生成的指令。该配置指令用于对连接器配置界面中的待配置字段进行操作,具体地,配置指令可以用于指示待操作的目标字段,例如,指示的目标字段为名称,配置指令还可以用于指示其他操作信息,此处不作具体赘述。
38.具体地,对配置指令指示的目标字段,执行配置指令对应的操作,以对待配置连接器进行配置。
39.步骤130,基于配置后的待配置连接器,对待集成应用进行集成处理。
40.具体地,基于各配置后的待配置连接器,以及之前已配置的连接器,实现服务、数据源、消息等的集成,进而实现对待集成应用的集成处理。
41.进一步地,本发明实施例的执行主体还提供包括api的创建、发布和下线的完整生命周期管理功能。
42.进一步地,本发明实施例的执行主体还支持集成http、dubbo、webservice、springcloud等协议;并支持引入支持脚本引擎的函数库,支持各类参数自定义转换;以及支持扩展本地函数组件,实现复杂逻辑的引入处理。
43.进一步地,本发明实施例的执行主体还提供页面调试工具,自动生成调试数据,简化api开发,降低api的维护成本。
44.进一步地,本发明实施例的执行主体还可以针对不同客户端应用的已授权调用的api生成对接的文档和sdk。
45.进一步地,本发明实施例的执行主体还提供集成应用的实时和历史日志能力,以用于支撑安全分析、合规审计、资源跟踪和问题定位等应用场景。
46.本发明实施例提供的应用集成方法,通过获取作用于待配置连接器的连接器配置界面上的配置指令,并执行该配置指令,以对待配置连接器进行配置,无需通过代码即可完成连接器的配置,进而基于配置后的待配置连接器,实现应用集成,即通过可视化图形界面的方式进行连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。
47.基于上述任一实施例,图2是本发明实施例提供的应用集成方法的流程示意图之二,如图2所示,在上述步骤130之后,该应用集成方法还包括:步骤210,确定集成后的目标数据源,以及所述目标数据源对应的数据更新配置界面。
48.需要说明的是,考虑到异构应用之间的技术差异,为了让不同的应用服务协调运作,实现不同服务之间的通讯,需要对集成后的目标数据源进行数据更新(数据映射或数据转换)。
49.此处,目标数据源可以包括但不限于以下至少一种:mysql、oracle、sqlserver等等。
50.此处,数据更新配置界面为对目标数据源进行配置的界面,其用于供用户基于该
配置界面进行数据源的配置,具体地,其用于供用户在该配置界面上触发数据更新指令。
51.在一实施例中,该数据更新配置界面包括数据更新字段,该数据更新字段可以包括但不限于以下至少一种:序号、目标字段名、参数位置、数据类型、是否必填、取值类型、源字段节点、源字段、源字段的值、函数设置等等。
52.步骤220,获取作用于所述数据更新配置界面的数据更新指令,并执行所述数据更新指令,以对所述目标数据源的数据结构和数据内容进行更新。
53.此处,数据更新指令是响应于用户通过本发明实施例的应用设备的配置操作,生成的指令。该数据更新指令用于对数据更新配置界面中的待配置字段进行操作,具体地,数据更新指令可以用于指示待操作的目标字段,例如,指示的目标字段为目标字段名,数据更新指令还可以用于指示其他操作信息,此处不作具体赘述。
54.具体地,对数据更新指令指示的目标字段,执行数据更新指令对应的操作,以对目标数据源的数据结构和数据内容进行更新。
55.此处,数据结构可以包括但不限于:目标字段名、参数位置、数据类型、是否必填、取值类型、源字段等等。
56.此处,数据内容可以包括但不限于:源字段的值、函数设置、参数的修改、函数的加工、变量的赋值等等。
57.需要说明的是,数据源集成后,用户可以根据目标应用系统的数据格式和数据结构要求,将输入的数据进行针对性的编排和转换,即数据更新,进而使数据源更好地集成。
58.进一步地,还可以对目标数据源的数据格式进行更新,例如,从xml格式转换成json格式。
59.本发明实施例提供的应用集成方法,通过获取作用于数据更新配置界面的数据更新指令,并执行该数据更新指令,以对目标数据源的数据结构和数据内容进行更新,无需通过代码即可完成数据源的数据更新,进而使数据源更好地集成,即通过可视化图形界面的方式进行数据源的数据更新,无需花费大量时间学习代码,用户只需专注于自身的业务需求,进一步减少了底层冗余的代码开发,有助于快速方便地进行数据更新,进而进一步降低应用集成的门槛,且进一步提高应用集成的效率,并进一步降低应用集成的成本。
60.基于上述任一实施例,图3是本发明实施例提供的应用集成方法的流程示意图之三,如图3所示,在上述步骤130之后,该应用集成方法还包括:步骤310,基于集成后的集成目标,确定可编排组件。
61.此处,集成目标可以包括但不限于以下至少一种:目标服务、目标数据源、目标消息、目标通信协议等等。
62.具体地,基于集成后的集成目标,确定对应的可编排组件,基于此,可编排组件可以包括但不限于以下至少一种:服务组件、数据源组件、消息组件、通信协议等等。
63.步骤320,获取作用于应用编排界面的编排指令,执行所述编排指令对应的操作,以基于所述可编排组件进行应用编排流程图绘制。
64.此处,应用编排界面为对可编排组件进行编排的界面,其用于供用户基于该应用编排界面进行组件的编排,具体地,其用于供用户在该应用编排界面上触发编排指令。该应用编排界面为编排流程图的绘制界面,即编排应用的建模界面。
65.该应用编排界面可以包括但不限于以下一种或多种:流程图绘制区域、组件选择
区域、连线选择区域、菜单栏区域、快捷操作区域、属性配置区域等等,本发明实施例对此不作具体限定。
66.其中,流程图绘制区域用于绘制应用编排流程图,具体地,其用于绘制业务需求所选择的技术路线的流程图。更为具体地,流程图绘制区域用于插入组件、拖拽组件并插入被拖拽组件、插入连线、拖拽连线并插入被拖拽连线、自定义绘制组件、对任两组件进行连线、生成连线的方向箭头、文本编辑、组件样式设置、连线样式设置、方向箭头样式设置、锚点样式设置、对齐线样式设置、插入流程图、拖拽流程图并插入流程图、移动流程图、翻转流程图、流程图样式设置等等。
67.其中,组件选择区域用于放置各组件,具体的,其用于放置各可编排组件,例如服务组件、数据源组件、信息组件、通信协议组件等等,以供从组件选择区域中选取组件插入至流程图绘制区域,或者,从组件选择区域中拖拽组件插入至流程图绘制区域。
68.其中,连线选择区域用于放置各连线,例如直线、折线、曲线等,以供从连线选择区域中选取连线(点击连线)插入至流程图绘制区域,或者,从连线选择区域中拖拽连线插入至流程图绘制区域。
69.其中,菜单栏区域用于放置功能选项,该功能选项用于提供流程图的编辑功能。
70.其中,快捷操作区域用于放置快捷的功能选项,该快捷的功能选项用于提供流程图的快捷编辑功能,从而提升流程图的编辑效率。
71.其中,属性配置区域用于进行属性配置,其可以用于对组件进行属性配置,也可以用于对连线进行属性配置。
72.此处,编排指令是响应于用户通过本发明实施例的应用设备的编排操作,生成的指令。
73.该编排指令可以在应用编排界面中的所有区域中触发。例如,流程图绘制区域中触发组件拖拽指令、连线拖拽指令、组件自定义指令、组件连线指令、连线方向确定指令、文本编辑指令、样式操作指令、组件点击指令、连线点击指令、组件翻转指令、连线翻转指令、流程图点击指令、流程图拖拽指令、流程图设置指令、流程图翻转指令等等;组件选择区域中触发组件拖拽指令、组件点击指令等等;菜单栏区域中触发功能点击指令、功能拖拽指令等等;快捷操作区域中触发功能点击指令、功能拖拽指令等等;属性配置区域中触发组件属性配置指令、连线属性配置指令等等。
74.该编排指令包括组件操作指令和其他元素操作指令。该组件操作指令用于对组件进行操作,具体地,组件操作指令可以用于指示待操作的目标组件,例如,指示的待操作的目标组件为被拖拽组件或新增组件或待连接组件或待编辑内容的组件或待设置样式内容的组件或待配置属性的组件等等,当然,组件操作指令还可以用于指示其他操作信息,此处不作具体赘述。该其他元素操作指令用于对除组件外的其他元素进行操作,其他元素如连线、流程图、方向箭头、网格、对齐线等等。
75.需要说明的是,该编排指令可以通过点击执行主体的显示屏幕触发,也可以通过输入设备触发,该输入设备可以包括但不限于:鼠标和键盘等等。例如,根据各类鼠标事件触发操作指令,或者,根据键盘快捷键触发操作指令。
76.该编排指令可以包括但不限于以下一种或多种:组件拖拽指令、连线拖拽指令、组件自定义指令、组件连线指令、连线方向确定指令、文本编辑指令、样式操作指令、组件点击
指令、连线点击指令、组件翻转指令、连线翻转指令、流程图点击指令、流程图拖拽指令、流程图设置指令、流程图翻转指令、功能点击指令、功能拖拽指令、组件属性配置指令、连线属性配置指令等等。
77.具体地,执行组件拖拽指令、组件自定义指令、文本编辑指令、样式操作指令或组件属性配置指令对应的操作,可以为编排应用提供组件,即用于提供业务需求所选择的组件。执行连线拖拽指令、连线方向确定指令、样式操作指令或连线属性配置指令对应的操作,可以将组件进行连接,即用于确定编排路线。
78.步骤330,基于各编排指令确定的应用编排流程图,确定编排后的编排应用。
79.其中,所述各编排指令包括组件操作指令,所述组件操作指令用于指示待操作组件,以及用于指示对所述待操作组件进行操作的操作内容。
80.具体地,执行若干次步骤320,最终基于各编排指令确定得到应用编排流程图;导出应用编排流程图对应的图数据,基于该图数据确定编排应用。更为具体地,确定应用编排流程图指示的各组件,并确定服务编排流程图指示的各组件之间的连接关系,基于该连接关系,对各组件进行聚合处理,得到该编排应用。
81.例如,该应用编排流程图包括第一组件、第二组件和第三组件,第一组件和第二组件并列连接后与第三组件连接,基于该应用编排流程图,确定第一组件和第二组件的第一连接关系,并确定二者与第三组件的第二连接关系,从而基于该第一连接关系与第二连接关系,对第一组件、第二组件和第三组件进行聚合处理,得到三者的编排应用。
82.此处,组件操作指令用于对组件进行操作,具体地,组件操作指令可以用于指示待操作的目标罪案,例如,指示的待操作的目标组件为被拖拽组件或新增组件或待连接组件或待编辑内容的组件或待设置样式内容的组件或待配置属性的组件等等。
83.该组件操作指令还可以用于指示对组件进行操作的操作内容,该操作内容可以包括但不限于:组件的拖拽操作、组件的自定义操作(如组件图形的绘制操作)、组件的连线操作、组件的文本编辑操作、组件的样式设置操作、组件的属性配置操作等等。当然,组件操作指令还可以用于指示其他操作信息,此处不作具体赘述。
84.该组件操作指令可以包括但不限于以下一种或多种:组件拖拽指令、组件自定义指令、组件连线指令、文本编辑指令、样式操作指令、组件点击指令、组件翻转指令、组件属性配置指令等等。
85.需要说明的是,应用集成后通过拖拽配置方式实现应用的编排,例如,实现接入资源的路由、动态路由、数据转换、逻辑处理等,对集成的编排应用可以使集成接口功能更加丰富,减少上下游双方业务系统集成的成本。
86.本发明实施例提供的应用集成方法,获取作用于应用编排界面的编排指令,执行编排指令对应的操作,以基于可编排组件进行应用编排流程图绘制;基于各编排指令确定的应用编排流程图,确定编排后的编排应用,无需通过代码即可完成应用的编排,即通过可视化图形界面的方式进行应用的编排,无需花费大量时间学习代码,用户只需专注于自身的业务需求,进一步减少了底层冗余的代码开发,有助于快速方便地进行应用编排,进而降低应用编排的门槛,且提高应用编排的效率,并降低应用编排的成本。
87.基于上述任一实施例,所述编排指令为所述组件操作指令的组件参数配置指令,所述执行所述编排指令对应的操作,包括:
确定所述组件参数配置指令指示的待配置组件,以及所述待配置组件的配置参数;基于所述配置参数,对所述待配置组件进行参数配置。
88.此处,组件参数配置指令用于在应用编排界面中进行参数配置。具体地,组件参数配置指令可以用于指示待配置组件;还可以用于指示待配置的配置参数。
89.组件参数配置指令是响应于用户通过本发明实施例提供的方法的执行主体的参数配置操作,生成的指令,例如,用户通过输入配置参数,触发对应的组件参数配置指令,此时,执行主体获取该组件参数配置指令。
90.本发明实施例提供的应用集成方法,确定组件参数配置指令指示的待配置组件,以及待配置组件的配置参数;基于配置参数,对待配置组件进行参数配置,从而无需通过代码即可完成组件的参数配置,进而无需通过代码即可完成应用的编排,即通过可视化图形界面的方式进行应用的编排,无需花费大量时间学习代码,用户只需专注于自身的业务需求,进一步减少了底层冗余的代码开发,有助于快速方便地进行应用编排,进而降低应用编排的门槛,且提高应用编排的效率,并降低应用编排的成本。
91.基于上述任一实施例,在上述步骤130之后,该应用集成方法还包括:确定待执行任务;获取作用于任务调度配置界面的调度配置指令,并执行所述调度配置指令,以对所述待执行任务进行配置。
92.具体地,根据预先制定的任务计划,基于集成后的目标应用,确定待执行任务。该预先制定的任务计划可以包括但不限于:数据集成任务、定时任务、实时任务、接入业务消息任务、使用方的主动调用任务等等。
93.其中,数据集成任务规定了源端到目标端的数据集成规则,包括两端的数据类型、数据字段的映射规则、数据集成的过滤条件等等。定时任务用于定时获取源端数据并集成到目标端。实时任务用于实现源端到目标端数据的实时同步及增量同步。接入业务消息任务用于通过消息的方式驱动应用集成的过程。使用方的主动调用,通过api调用的方式驱动应用集成的过程。
94.此处,任务调度配置界面为对待执行任务进行配置的界面,其用于供用户基于该任务调度配置界面进行任务的配置,具体地,其用于供用户在该任务调度配置界面上触发调度配置指令。
95.该任务调度配置界面包括任务配置字段,该任务配置字段可以包括但不限于以下至少一种:任务名称、任务描述、任务类型、最大页码、请求超时时间、执行频率、时间补偿、请求参数、响应参数等等。其中,请求参数可以包括但不限于:序号、参数名、参数类型、当前值、是否必填、数组元素泛型等等。响应参数可以包括但不限于:序号、参数名、参数类型、数组元素泛型、描述、操作等等。进一步地,任务名称、任务类型、执行频率、时间补偿为必填字段,即必配置字段。
96.此处,调度配置指令是响应于用户通过本发明实施例的应用设备的配置操作,生成的指令。该调度配置指令用于对任务调度配置界面中的待配置字段进行操作,具体地,调度配置指令可以用于指示待操作的目标字段,例如,指示的目标字段为任务名称,配置指令还可以用于指示其他操作信息,此处不作具体赘述。
97.具体地,对调度配置指令指示的目标字段,执行调度配置指令对应的操作,以对待执行任务进行配置。
98.本发明实施例提供的应用集成方法,获取作用于任务调度配置界面的调度配置指令,并执行调度配置指令,从而无需通过代码即可完成待执行任务的配置,进而无需通过代码即可完成应用的集成,即通过可视化图形界面的方式进行应用的集成,无需花费大量时间学习代码,用户只需专注于自身的业务需求,进一步减少了底层冗余的代码开发,有助于快速方便地进行应用集成,进而进一步降低应用集成的门槛,且进一步提高应用集成的效率,并进一步降低应用集成的成本。
99.基于上述任一实施例,在上述步骤130之后,该应用集成方法还包括:确定集成后的目标数据源,以及所述目标数据源对应的数据查询参数设定界面;获取作用于所述数据查询参数设定界面的参数设定指令;基于所述参数设定指令,确定数据库查询语言语句,所述数据库查询语言语句用于查询所述目标数据源中的数据。
100.此处,目标数据源可以包括但不限于以下至少一种:mysql、oracle、sqlserver等等。
101.此处,数据查询参数设定界面为对目标数据源进行数据查询的界面,其用于供用户基于该数据查询参数设定界面进行数据查询,具体地,其用于供用户在该数据查询参数设定界面上触发参数设定指令。
102.具体地,基于参数设定指令指示的自然语言文本,确定数据库查询语言语句。更为具体地,基于转换模型,对自然语言文本进行转换处理,得到自然语言文本对应的数据库查询语言语句。
103.其中,转换模型用于将自然语言文本转换为数据库查询语言语句,以供基于数据库查询语言语句对目标数据源进行查询,得到查询结果。该转换模型可以为nl2sql中的转换模型,该转换模型的具体结构可以根据实际需要进行设定,本发明实施例在此不做具体限定。
104.需要说明的是,对接各种数据源,无需编码快速生成新的api。
105.本发明实施例提供的应用集成方法,获取作用于数据查询参数设定界面的参数设定指令,基于参数设定指令,确定数据库查询语言语句,从而无需通过代码即可完成数据库查询语言语句的生成,进而无需通过代码即可完成应用的集成,即通过可视化图形界面的方式进行应用的集成,无需花费大量时间学习代码,用户只需专注于自身的业务需求,进一步减少了底层冗余的代码开发,有助于快速方便地进行应用集成,进而进一步降低应用集成的门槛,且进一步提高应用集成的效率,并进一步降低应用集成的成本。
106.基于上述任一实施例,所述待配置连接器包括服务连接器、数据连接器、消息连接器中的至少一种;所述服务连接器用于对待集成服务进行集成处理;所述数据连接器用于对待集成数据源进行集成处理;所述消息连接器用于消费消息,以及生产消息。
107.其中,服务连接器用于对待集成服务进行集成处理,基于此,可无缝与企业原有的微服务框架进行集成,兼容nacos、zk、eureka、consul等多种服务注册中心,提供api网关的全量管控api。此外,实现企业已有restapi、soap、dubbo、springcloud、rfc等接口的注册、协议转换和零代码服务调用。
108.其中,数据连接器用于对待集成数据源进行集成处理,基于此,可快速链接各种数据源。该数据源可以包括但不限于:mysql、oracle、sqlserver等。此外,通过对数据源的链接可快速发布数据类api接口服务。进一步地,通过数据库相关信息的注册,包括连接池的相关信息的配置,完成数据源的统一管理和使用。
109.其中,消息链接用于消费消息,以及生产消息,基于此,可以快速实现多种mq(kafka、rabbitmq、rocketmq、activemq、mqtt)消息的统一消费和管理。进一步地,通过消息总线mq可以统一消费消息并自动分发给业务编排流程;通过mq把原来同步调用的api实现异步调用,把不同生产以及消费速率不一样的api进行流量的削峰,通过mq可增强应用集成的稳定性和可靠性。此外,可以快速实现mq消息的生产,多种mq无需代码即可一键发布成为restful api,通过api即可实现mq与其他业务系统的打通。换言之,可以对接各种消息中间件,无需编码即可快速收发消息。
110.在实际应用过程中,本发明实施例提供的应用集成平台是一个全栈式的应用与数据集成平台,聚焦应用和数据连接,提供数据、api和消息的集成能力,适用于多种常见的企业系统集成场景。具体地,通过低代码的方式将企业内外部间不同的系统或业务连接到一个统一的平台中,也能通过复用集成最佳实践范例、快速搭建系统集成模型实现各个系统间的资源整合、集成编排和传递、业务衔接等功能,满足企业轻量级、全方位、高灵活度的一体化系统集成需求,有效降低企业系统集成周期和难度。此外,应用集成平台还提供丰富应用管理和运维能力,可视化监控和日志界面进一步帮助用户降低了运维成本。为企业提供开发、调试、发布、运维一体化的集成解决方案,大幅提高实施人员的集成效率、降低集成任务的后期运维成本。具体地,应用集成平台提供全方位的集成能力,支持各种集成场景,例如应用程序集成、服务集成、数据集成、消息集成、b2b 生态系统集成等等。此外,灵活的集成应用编排,用户在控制台配置界面通过拖拽组件并设置参数即可完成复杂的集成业务逻辑,同时支持脚本语言,可以面向广大的业务人员和技术人员提供灵活的开发模式来满足复杂集成业务场景的需求,大大提升集成流程的编排效率和能力。此外,降低集成成本,相较其他传统的系统集成产品而言,统一的集成平台、沉淀业界数据集成范例、可复用的集成最佳实践等,能大大避免定制化开发、节省成本并缩短开发周期。
111.下面对本发明提供的应用集成装置进行描述,下文描述的应用集成装置与上文描述的应用集成方法可相互对应参照。
112.图4是本发明实施例提供的应用集成装置的结构示意图,如图4所示,该应用集成装置,包括:确定模块410,用于确定待配置连接器,以及所述待配置连接器的连接器配置界面;执行模块420,用于获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;处理模块430,用于基于配置后的待配置连接器,对待集成应用进行集成处理。
113.本发明实施例提供的应用集成装置,通过获取作用于待配置连接器的连接器配置界面上的配置指令,并执行该配置指令,以对待配置连接器进行配置,无需通过代码即可完成连接器的配置,进而基于配置后的待配置连接器,实现应用集成,即通过可视化图形界面的方式进行连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,
减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。
114.基于上述任一实施例,该装置还包括数据更新模块,该数据更新模块用于:确定集成后的目标数据源,以及所述目标数据源对应的数据更新配置界面;获取作用于所述数据更新配置界面的数据更新指令,并执行所述数据更新指令,以对所述目标数据源的数据结构和数据内容进行更新。
115.基于上述任一实施例,该装置还包括应用编排模块,该应用编排模块用于:基于集成后的集成目标,确定可编排组件;获取作用于应用编排界面的编排指令,执行所述编排指令对应的操作,以基于所述可编排组件进行应用编排流程图绘制;基于各编排指令确定的应用编排流程图,确定编排后的编排应用;其中,所述各编排指令包括组件操作指令,所述组件操作指令用于指示待操作组件,以及用于指示对所述待操作组件进行操作的操作内容。
116.基于上述任一实施例,所述编排指令为所述组件操作指令的组件参数配置指令,该应用编排模块还用于:确定所述组件参数配置指令指示的待配置组件,以及所述待配置组件的配置参数;基于所述配置参数,对所述待配置组件进行参数配置。
117.基于上述任一实施例,该装置还包括任务配置模块,该任务配置模块用于:确定待执行任务;获取作用于任务调度配置界面的调度配置指令,并执行所述调度配置指令,以对所述待执行任务进行配置。
118.基于上述任一实施例,该装置还包括数据查询模块,该数据查询模块用于:确定集成后的目标数据源,以及所述目标数据源对应的数据查询参数设定界面;获取作用于所述数据查询参数设定界面的参数设定指令;基于所述参数设定指令,确定数据库查询语言语句,所述数据库查询语言语句用于查询所述目标数据源中的数据。
119.基于上述任一实施例,所述待配置连接器包括服务连接器、数据连接器、消息连接器中的至少一种;所述服务连接器用于对待集成服务进行集成处理;所述数据连接器用于对待集成数据源进行集成处理;所述消息连接器用于消费消息,以及生产消息。
120.图5示例了一种电子设备的实体结构示意图,如图5所示,该电子设备可以包括:处理器(processor)510、通信接口(communications interface)520、存储器(memory)530和通信总线540,其中,处理器510,通信接口520,存储器530通过通信总线540完成相互间的通信。处理器510可以调用存储器530中的逻辑指令,以执行应用集成方法,该方法包括:确定待配置连接器,以及所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。
121.此外,上述的存储器530中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括:u盘、移动硬盘、只读存储器(rom,read-only memory)、随机存取存储器(ram,random access memory)、磁碟或者光盘等各种可以存储程序代码的介质。
122.另一方面,本发明还提供一种计算机程序产品,所述计算机程序产品包括计算机程序,计算机程序可存储在非暂态计算机可读存储介质上,所述计算机程序被处理器执行时,计算机能够执行上述各方法所提供的应用集成方法,该方法包括:确定待配置连接器,以及所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。
123.又一方面,本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现以执行上述各方法提供的应用集成方法,该方法包括:确定待配置连接器,以及所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。
124.以上所描述的装置实施例仅仅是示意性的,其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下,即可以理解并实施。
125.通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件。基于这样的理解,上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品可以存储在计算机可读存储介质中,如rom/ram、磁碟、光盘等,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。
126.最后应说明的是:以上实施例仅用以说明本发明的技术方案,而非对其限制;尽管参照前述实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。
127.以上实施方式仅用于说明本发明,而非对本发明的限制。尽管参照实施例对本发明进行了详细说明,本领域的普通技术人员应当理解,对本发明的技术方案进行各种组合、修改或者等同替换,都不脱离本发明技术方案的精神和范围,均应涵盖在本发明的权利要求范围中。
技术特征:
1.一种应用集成方法,其特征在于,包括:确定待配置连接器,以及所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。2.根据权利要求1所述的应用集成方法,其特征在于,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定集成后的目标数据源,以及所述目标数据源对应的数据更新配置界面;获取作用于所述数据更新配置界面的数据更新指令,并执行所述数据更新指令,以对所述目标数据源的数据结构和数据内容进行更新。3.根据权利要求1所述的应用集成方法,其特征在于,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:基于集成后的集成目标,确定可编排组件;获取作用于应用编排界面的编排指令,执行所述编排指令对应的操作,以基于所述可编排组件进行应用编排流程图绘制;基于各编排指令确定的应用编排流程图,确定编排后的编排应用;其中,所述各编排指令包括组件操作指令,所述组件操作指令用于指示待操作组件,以及用于指示对所述待操作组件进行操作的操作内容。4.根据权利要求3所述的应用集成方法,其特征在于,所述编排指令为所述组件操作指令的组件参数配置指令;所述执行所述编排指令对应的操作,包括:确定所述组件参数配置指令指示的待配置组件,以及所述待配置组件的配置参数;基于所述配置参数,对所述待配置组件进行参数配置。5.根据权利要求1所述的应用集成方法,其特征在于,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定待执行任务;获取作用于任务调度配置界面的调度配置指令,并执行所述调度配置指令,以对所述待执行任务进行配置。6.根据权利要求1所述的应用集成方法,其特征在于,所述基于配置后的待配置连接器,对待集成应用进行集成处理,之后还包括:确定集成后的目标数据源,以及所述目标数据源对应的数据查询参数设定界面;获取作用于所述数据查询参数设定界面的参数设定指令;基于所述参数设定指令,确定数据库查询语言语句,所述数据库查询语言语句用于查询所述目标数据源中的数据。7.根据权利要求1至6中任一项所述的应用集成方法,其特征在于,所述待配置连接器包括服务连接器、数据连接器、消息连接器中的至少一种;所述服务连接器用于对待集成服务进行集成处理;所述数据连接器用于对待集成数据源进行集成处理;所述消息连接器用于消费消息,以及生产消息。
8.一种应用集成装置,其特征在于,包括:确定模块,用于确定待配置连接器,以及所述待配置连接器的连接器配置界面;执行模块,用于获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;处理模块,用于基于配置后的待配置连接器,对待集成应用进行集成处理。9.一种电子设备,包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述程序时实现如权利要求1至7任一项所述应用集成方法。10.一种非暂态计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至7任一项所述应用集成方法。
技术总结
本发明涉及数据处理技术领域,提供一种应用集成方法、装置、电子设备和存储介质,方法包括:确定待配置连接器,以及所述待配置连接器的连接器配置界面;获取作用于所述连接器配置界面上的配置指令,并执行所述配置指令,以对所述待配置连接器进行配置;基于配置后的待配置连接器,对待集成应用进行集成处理。本发明通过可视化图形界面的方式进行连接器的配置,无需花费大量时间学习代码,用户只需专注于自身的业务需求,减少了底层冗余的代码开发,有助于快速方便地配置连接器,进而降低应用集成的门槛,且提高应用集成的效率,并降低应用集成的成本。成的成本。成的成本。
技术研发人员:
汪海霖
受保护的技术使用者:
美云智数科技有限公司
技术研发日:
2023.02.10
技术公布日:
2023/3/10