-
公开(公告)号:CN114510471B
公开(公告)日:2023-07-21
申请号:CN202210142177.X
申请日:2022-02-16
Applicant: 北京九栖科技有限责任公司
IPC: G06F16/215 , G06F16/25 , G06F9/445
Abstract: 本发明公开了一种用于大数据平台实时状态计算的方法、服务器及存储介质,本发明通过一套通用的实时订阅程序的框架,降低基于状态数据处理的难度。该框架分为两层,第一层的框架负责通用的数据订阅和处理,第二层框架负责状态的处理和分发,这样双层的框架设计使得最终的业务插件只需要负责处理状态数据的更新逻辑和基于状态和输入数据的业务数据输出即可。二级插件的设置使得在大数据处理中对基于状态的数据处理这一较为复杂的业务逻辑大幅度简化,相关的开发只需要实现这一过程中的几个步骤即可,而通用的操作均交由两层的框架来实现。
-
公开(公告)号:CN116991607B
公开(公告)日:2023-12-22
申请号:CN202311244494.3
申请日:2023-09-26
Applicant: 北京九栖科技有限责任公司
Abstract: 本发明涉及大数据分析技术领域,具体涉及一种用于大数据中台和平台间通信的适配方法、系统及设备,方法包括:程序上传:对大数据中台已有的程序文件和依赖文件进行分类管理,并批量上传到大数据平台;库表建立:确定大数据中台所需的库表,在数据总线上为相应的库表申请资源,在大数据平台中进行单张库表建立或批量库表建立;任务上传:将大数据中台所需的实时任务和/或离线任务批量上传至所述大数据平台;任务执行:将大数据中台所需执行的异步任务与大数据平台提供的接口进行适配,并驱动大数据平台执行相应任务。本发明可实现大数据中台和大数据平台间快速适配和自动化对接。
-
公开(公告)号:CN116991607A
公开(公告)日:2023-11-03
申请号:CN202311244494.3
申请日:2023-09-26
Applicant: 北京九栖科技有限责任公司
Abstract: 本发明涉及大数据分析技术领域,具体涉及一种用于大数据中台和平台间通信的适配方法、系统及设备,方法包括:程序上传:对大数据中台已有的程序文件和依赖文件进行分类管理,并批量上传到大数据平台;库表建立:确定大数据中台所需的库表,在数据总线上为相应的库表申请资源,在大数据平台中进行单张库表建立或批量库表建立;任务上传:将大数据中台所需的实时任务和/或离线任务批量上传至所述大数据平台;任务执行:将大数据中台所需执行的异步任务与大数据平台提供的接口进行适配,并驱动大数据平台执行相应任务。本发明可实现大数据中台和大数据平台间快速适配和自动化对接。
-
公开(公告)号:CN114510471A
公开(公告)日:2022-05-17
申请号:CN202210142177.X
申请日:2022-02-16
Applicant: 北京九栖科技有限责任公司
IPC: G06F16/215 , G06F16/25 , G06F9/445
Abstract: 本发明公开了一种用于大数据平台实时状态计算的方法、服务器及存储介质,本发明通过一套通用的实时订阅程序的框架,降低基于状态数据处理的难度。该框架分为两层,第一层的框架负责通用的数据订阅和处理,第二层框架负责状态的处理和分发,这样双层的框架设计使得最终的业务插件只需要负责处理状态数据的更新逻辑和基于状态和输入数据的业务数据输出即可。二级插件的设置使得在大数据处理中对基于状态的数据处理这一较为复杂的业务逻辑大幅度简化,相关的开发只需要实现这一过程中的几个步骤即可,而通用的操作均交由两层的框架来实现。
-
-
-