一种基于云原生架构的大数据流处理方法和装置

基本信息

申请号 CN202010734377.5 申请日 -
公开(公告)号 CN111880899A 公开(公告)日 2020-11-03
申请公布号 CN111880899A 申请公布日 2020-11-03
分类号 G06F9/455(2006.01)I 分类 计算;推算;计数;
发明人 商子豪;曲茂强;薛爱梅;张春涛;葛亮 申请(专利权)人 山东迪特智联信息科技有限责任公司
代理机构 济南竹森知识产权代理事务所(普通合伙) 代理人 吕利敏
地址 250000山东省济南市历下区浆水泉路16号卓越时代广场一号楼1109
法律状态 -

摘要

摘要 本发明的实施例公开了一种基于云原生架构的大数据流处理方法、装置、电子设备及存储介质,涉及大数据流处理技术领域,用于避免大数据流处理任务执行的资源占用及插件冲突,提高平台运行安全性和稳定性。所述方法包括:接收服务器发送的大数据流处理任务,该任务中包含所需的插件镜像信息、Git仓库地址信息、输入和输出信息;通知Docker Engine从镜像仓库拉取并运行相应的插件镜像,使插件开始运行;插件运行后访问Git仓库,获取任务上下文数据;插件从数据源获取数据并进行数据处理,处理完毕后将任务处理结果和日志信息记录到Git仓库中并更新任务上下文数据;通知服务器任务已执行完成,并通知Docker Engine销毁运行的插件实例,释放占用的资源。