一種流數(shù)據(jù)的實時處理方法、裝置、設(shè)備及介質(zhì)

基本信息

申請?zhí)?/td> 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 分類 計算；推算；計數(shù);
發(fā)明人 姚永康;殷濤;顧杰;司三三 申請（專利權(quán)）人 南京慧爾視軟件科技有限公司
代理機構(gòu) 北京品源專利代理有限公司 代理人 -
地址 211100江蘇省南京市江寧區(qū)蘇源大道19號九龍湖國際企業(yè)總部園B1座7樓（江寧開發(fā)區(qū)）
法律狀態(tài) -

摘要

摘要 本發(fā)明實施例公開了一種流數(shù)據(jù)的實時處理方法、裝置、設(shè)備及介質(zhì)。其中，該方法包括：若監(jiān)聽到流數(shù)據(jù)傳入操作，則讀取所述流數(shù)據(jù)的數(shù)據(jù)類型；通過主題與所述數(shù)據(jù)類型相適配的消息中間件接收所述流數(shù)據(jù)；若檢測到第一觸發(fā)事件，則按照第一粒度時間窗口以及第一粒度時間窗口的預(yù)留時段，對各主題的流數(shù)據(jù)進行處理，得到第一粒度時間窗口處理結(jié)果；其中，第一粒度時間窗口按照第一窗口跨度時長順次連接；所述第一粒度時間窗口的預(yù)留時段為后一第一粒度時間窗口內(nèi)與前一第一粒度時間窗口連接的第一預(yù)留時段跨度時長的時段；所述第一窗口跨度時長大于所述第一預(yù)留時段跨度時長。本技術(shù)方案，能夠?qū)崿F(xiàn)對流數(shù)據(jù)進行實時的業(yè)務(wù)分析和處理的效果。