基于批流一體的數(shù)據(jù)處理方法、裝置、計算機設(shè)備和介質(zhì)

基本信息

申請?zhí)?/td> CN202111318823.5 申請日 -
公開（公告）號 CN113779094B 公開（公告）日 2022-03-22
申請公布號 CN113779094B 申請公布日 2022-03-22
分類號 G06F16/2455（2019.01）I;G06F16/25（2019.01）I;G06F16/28（2019.01）I 分類 計算；推算；計數(shù);
發(fā)明人 王博一;王曉;霍星志;郭宇鵬;毛少將 申請（專利權(quán)）人 通號通信信息集團有限公司
代理機構(gòu) 北京天昊聯(lián)合知識產(chǎn)權(quán)代理有限公司 代理人 彭瑞欣;姜春咸
地址 100070北京市豐臺區(qū)汽車博物館南路1號院中國通號大廈A座601室
法律狀態(tài) -

摘要

摘要 本公開提供一種基于批流一體的數(shù)據(jù)處理方法，所述方法應(yīng)用于數(shù)據(jù)處理裝置，數(shù)據(jù)處理裝置包括數(shù)據(jù)應(yīng)用層和多個處理層，各處理層形成處理鏈路，所述方法包括：獲取待處理數(shù)據(jù)；根據(jù)處理鏈路逐層處理待處理數(shù)據(jù)，得到第一數(shù)據(jù)；其中，在各處理層中，對輸入本處理層的數(shù)據(jù)進行處理，將處理后的數(shù)據(jù)輸入至下一個處理層；在數(shù)據(jù)應(yīng)用層中處理第一數(shù)據(jù)，得到第二數(shù)據(jù)；響應(yīng)于檢測出第二數(shù)據(jù)發(fā)生數(shù)據(jù)錯誤，在發(fā)生數(shù)據(jù)錯誤的處理層中，根據(jù)本處理層的離線數(shù)據(jù)對發(fā)生數(shù)據(jù)錯誤的數(shù)據(jù)進行修正，將修正后的數(shù)據(jù)輸入至下一個處理層，以便下一個處理層對輸入的數(shù)據(jù)進行處理。本公開還提供一種數(shù)據(jù)處理裝置、計算機設(shè)備和介質(zhì)。