一种流数据的实时处理方法、装置、设备及介质
基本信息
| 申请号 | CN202210408628.X | 申请日 | - |
| 公开（公告）号 | CN114723413A | 公开（公告）日 | 2022-07-08 |
| 申请公布号 | CN114723413A | 申请公布日 | 2022-07-08 |
| 分类号 | G06Q10/10（2012.01）I;G06Q50/30（2012.01）I;G08G1/01（2006.01）I | 分类 | 计算；推算；计数; |
| 发明人 | 姚永康;殷涛;顾杰;司三三 | 申请（专利权）人 | 南京慧尔视软件科技有限公司 |
| 代理机构 | 北京品源专利代理有限公司 | 代理人 | - |
| 地址 | 211100江苏省南京市江宁区苏源大道19号九龙湖国际企业总部园B1座7楼（江宁开发区） | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明实施例公开了一种流数据的实时处理方法、装置、设备及介质。其中，该方法包括：若监听到流数据传入操作，则读取所述流数据的数据类型；通过主题与所述数据类型相适配的消息中间件接收所述流数据；若检测到第一触发事件，则按照第一粒度时间窗口以及第一粒度时间窗口的预留时段，对各主题的流数据进行处理，得到第一粒度时间窗口处理结果；其中，第一粒度时间窗口按照第一窗口跨度时长顺次连接；所述第一粒度时间窗口的预留时段为后一第一粒度时间窗口内与前一第一粒度时间窗口连接的第一预留时段跨度时长的时段；所述第一窗口跨度时长大于所述第一预留时段跨度时长。本技术方案，能够实现对流数据进行实时的业务分析和处理的效果。 |
