[發(fā)明專利]一種數(shù)據(jù)對賬方法、系統(tǒng)及數(shù)據(jù)系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201710060428.9
• 申請日: 2017-01-24
• 公開（公告）號: CN108345621B
• 公開（公告）日: 2022-03-08
• 發(fā)明（設計）人: 廖清華
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: G06F16/17
• 分類號: G06F16/17;G06F16/18;G06F16/182
• 代理公司: 深圳翼盛智成知識產(chǎn)權事務所(普通合伙) 44300
• 代理人: 黃威

本發(fā)明實施例公開了數(shù)據(jù)對賬方法、系統(tǒng)及數(shù)據(jù)系統(tǒng)，應用于信息處理技術領域。在本實施例的方法中，數(shù)據(jù)對賬系統(tǒng)會獲取數(shù)據(jù)系統(tǒng)中的各個節(jié)點獲取某一特征屬性即第一特征屬性的包裝消息的日志信息，然后根據(jù)日志信息中包裝消息的創(chuàng)建時間和消息條數(shù)，統(tǒng)計多個節(jié)點分別獲取的各個對賬時間點上第一特征屬性的業(yè)務消息的消息條數(shù)，如果某一對賬時間點上多個節(jié)點分別對應的消息條數(shù)不一致，則進行第一告警提示。簡化了數(shù)據(jù)對賬系統(tǒng)對于某一特征屬性的業(yè)務消息的消息條數(shù)的統(tǒng)計，只需統(tǒng)計某一特征屬性的包裝消息內(nèi)的業(yè)務消息的條數(shù)即可，且本實施例中相鄰的對賬時間點之間的距離可以較小，比如為1分鐘，滿足了一些具有較強實時性要求的數(shù)據(jù)。

技術領域

本發(fā)明涉及信息處理技術領域，特別涉及一種數(shù)據(jù)對賬方法、系統(tǒng)及數(shù)據(jù)系統(tǒng)。

背景技術

數(shù)據(jù)對賬主要是針對數(shù)據(jù)系統(tǒng)(比如大數(shù)據(jù)接入系統(tǒng)等)中數(shù)據(jù)消息流通時的收發(fā)消息進行核對和校驗，以驗證數(shù)據(jù)消息流通的正確性和可靠性。

現(xiàn)有技術中一般采用小時數(shù)據(jù)對賬方法，主要是當某個業(yè)務的業(yè)務數(shù)據(jù)接入到數(shù)據(jù)系統(tǒng)時，業(yè)務數(shù)據(jù)在數(shù)據(jù)系統(tǒng)的各個節(jié)點傳輸過程中，通過數(shù)據(jù)對賬系統(tǒng)監(jiān)控各個節(jié)點接收該業(yè)務下的業(yè)務消息的信息，將各個節(jié)點對應的業(yè)務消息的信息進行匹對，從而保障業(yè)務數(shù)據(jù)在數(shù)據(jù)系統(tǒng)中傳輸?shù)囊恢滦浴?/p>

發(fā)明內(nèi)容

本發(fā)明實施例提供一種數(shù)據(jù)對賬方法、系統(tǒng)及數(shù)據(jù)系統(tǒng)，實現(xiàn)了根據(jù)數(shù)據(jù)系統(tǒng)中多個節(jié)點獲取第一特征屬性的包裝消息的日志信息，確定某一對賬時間點上多個節(jié)點分別對應的第一特征屬性的業(yè)務消息的消息條數(shù)的一致性。

本發(fā)明實施例提供一種數(shù)據(jù)對賬方法，包括：

獲取數(shù)據(jù)系統(tǒng)中包括的多個節(jié)點分別獲取第一特征屬性的包裝消息的日志信息，其中，所述包裝消息中包括所述第一特征屬性的多條業(yè)務消息，所述日志信息包括所述包裝消息中多條業(yè)務消息的消息條數(shù)，第一特征屬性和所述包裝消息的創(chuàng)建時間；

根據(jù)所述日志信息分別統(tǒng)計所述多個節(jié)點獲取的各個對賬時間點上所述第一特征屬性的業(yè)務消息的消息條數(shù)，其中，在某一對賬時間點上某一節(jié)點對應的消息條數(shù)為：所述某一節(jié)點獲取的，且創(chuàng)建時間在所述某一對賬時間點到其下一對賬時間點之間的，且具有所述第一特征屬性的包裝消息中業(yè)務消息的條數(shù)；

如果在某一對賬時間點上所述多個節(jié)點分別對應的消息條數(shù)不一致，進行第一告警提示，所述第一告警提示用于指示在所述某一對賬時間點第一特征屬性的業(yè)務消息在所述數(shù)據(jù)系統(tǒng)的傳輸出現(xiàn)故障。

本發(fā)明實施例提供一種數(shù)據(jù)對賬方法，應用于數(shù)據(jù)系統(tǒng)中，所述數(shù)據(jù)系統(tǒng)包括多個節(jié)點，所述方法包括：

所述多個節(jié)點中的第一節(jié)點將源端的業(yè)務消息按照某一維度特征進行分組；

所述第一節(jié)點根據(jù)所述分組創(chuàng)建包裝消息，所述包裝消息中包括所述包裝消息的創(chuàng)建時間及某一特征屬性的多條業(yè)務消息；

所述第一節(jié)點記錄第一日志信息，發(fā)送所述第一日志信息給數(shù)據(jù)對賬系統(tǒng)，所述第一日志信息中包括所述第一節(jié)點的地址信息，所述包裝消息中業(yè)務消息的消息條數(shù)，特征屬性及所述創(chuàng)建時間，以便所述數(shù)據(jù)對賬系統(tǒng)根據(jù)所述第一日志信息，確定所述第一節(jié)點獲取的與所述創(chuàng)建時間對應的對賬時間點上任一特征屬性的業(yè)務消息的消息條數(shù)，并進行對賬。

本發(fā)明實施例提供一種數(shù)據(jù)對賬系統(tǒng)，包括：

日志獲取單元，用于獲取數(shù)據(jù)系統(tǒng)中包括的多個節(jié)點分別獲取第一特征屬性的包裝消息的日志信息，其中，所述包裝消息中包括所述第一特征屬性的多條業(yè)務消息，所述日志信息包括所述包裝消息中多條業(yè)務消息的消息條數(shù)，第一特征屬性和所述包裝消息的創(chuàng)建時間；