实时流数据处理方法、系统、设备及存储介质
公开
摘要
本发明公开了一种实时流数据处理方法、系统、设备及存储介质。涉及计算机技术领域,其中一种实时流数据处理方法包括:通过获取预设的初始SQL语句数据;对初始SQL语句数据进行预处理,得到目标SQL语句数据;对目标SQL语句数据进行解析处理,得到表模式数据;将表模式数据输入至预设的Flink框架进行转换处理,生成实时流数据,实时流数据存储在预设的中间件中。通过本申请公开的实施例能够对初始SQL语句数据先进行预处理,以保持数据的一致性和高可用性,从而再利用Flink框架生成存储在预设的中间件中的实时流数据。
基本信息
专利标题 :
实时流数据处理方法、系统、设备及存储介质
专利标题(英):
暂无
公开(公告)号 :
CN114416793A
申请号 :
CN202210033729.3
公开(公告)日 :
2022-04-29
申请日 :
2022-01-12
授权号 :
暂无
授权日 :
暂无
发明人 :
贺子江杨磊
申请人 :
北京滴普科技有限公司
申请人地址 :
北京市海淀区彩和坊路8号4层406
代理机构 :
北京中政联科专利代理事务所(普通合伙)
代理人 :
赖学能
优先权 :
CN202210033729.3
主分类号 :
G06F16/2455
IPC分类号 :
G06F16/2455 G06F16/242
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F16/2455
••••查询执行
法律状态
2022-04-29 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载