[發明專利]一種報告數據處理結果的方法、系統及事件追蹤器

有效

• 申請號: 201310293733.4
• 申請日: 2013-07-12
• 公開（公告）號: CN104281627B
• 公開（公告）日: 2018-12-21
• 發明（設計）人: 封仲淹
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 林祥

本申請公開了一種報告數據處理結果的方法、系統及事件追蹤器，通過設置的事件追蹤器來對流水線過程進行實時追蹤，無論是流水線過程處理成功還是處理失敗，最終的處理結果都無需由節點間依次報告，而是由事件追蹤器直接向第一級節點報告，可極大地縮短處理結果傳遞至第一級節點的鏈路。

技術領域

本申請涉及計算機技術領域，尤其涉及一種報告數據處理結果的方法、系統及事件追蹤器。

背景技術

數據流經多個節點并由流經的多個節點分別進行處理的過程可視為流水線過程，所述流水線過程不局限于數據流經單個程序內部的多個節點的情況，還可以包括數據流經多個程序內的節點形成的流水線，這種流經多個程序內的節點形成的流水線過程多應用在分布式網絡架構中。

以數據流經圖1所示的節點拓撲架構為例，其中，A節點是流水線中的第一級節點，負責從外部獲取數據，并將獲取的數據逐級傳輸，直至數據流經所有的節點。假設A節點從外部獲取的數據是數據a，其流經圖1所示的節點拓撲架構的流水線過程如下：

1、A節點對獲取的數據a進行處理后，分別生成數據b和數據c，其中，數據b發送給下一級的B節點，數據c發送給下一級的C節點。

2、B節點對接收到的數據b進行處理后生成數據d1，并發送給下一級的D節點；C節點對接收到的數據c進行處理后生成數據d2，并發送給下一級的D節點。

3、D節點對接收到的數據d1和數據d2進行處理后，生成數據e并發送給下一級的E節點。

4、E節點對接收到的數據e進行處理，完成本次流水線過程。

在流水線過程結束后，作為流水線中第一級節點的A節點需要知道數據流經下級各節點時是否被正確處理，因此，在完成流水線過程后，從最低一級節點起，依次向上一級節點報告處理結果。以圖1所示的節點拓撲架構為例，當E節點對接收到的數據e成功處理后，各級節點向上一級節點報告處理結果的過程如下：

5、E節點向上一級的D節點報告的處理結果為數據e處理成功。

6、D節點向上一級的B節點報告的處理結果為數據d1處理成功，并向上一級的C節點報告的處理結果為數據d2處理成功。

7、B節點向上一級的A節點報告的處理結果為數據b處理成功，以及C節點向上一級的A節點報告的處理結果為數據c處理成功。

8、A節點最終確認數據a已被成功處理。

以上在流水線過程結束后（包括流水線過程成功結束和流水線過程失敗結束）報告處理結果的方案中，處理結果（包括處理成功和處理失敗）報告傳遞至第一級節點的鏈路過長，當應用在分布式網絡架構中，會增加處理結果數據包丟失的風險；同時，由于處理結果報告傳遞的鏈路過長，還可能會延長第一級節點針對處理結果的響應時間，特別是出現某一節點對接收到的數據處理失敗的情況時，處理結果報告傳遞的鏈路過長的缺陷更加明顯。

例如，E節點對接收到的數據e處理失敗時，E節點首先向上一級的D節點報告的處理結果為數據e處理失敗，D節點再向上一級的B節點和C節點分別報告的處理結果為數據d1、數據d2處理失敗，最后再由B節點和C節點分別向上一級的A節點報告的處理結果為數據b、數據c處理失敗，此時A節點才能最終確認數據a處理失敗。也就是說，E節點處理失敗的處理結果要經過D節點、C節點、B節點后才能達到A節點，由于報告處理失敗的鏈路過長，會延長第一級節點對處理失敗的響應時間，出現失敗響應延遲的問題。

發明內容

本申請實施例提供了一種報告數據處理結果的方法、系統及事件追蹤器，用以解決現有技術中存在的在流水線過程結束后，處理結果報告傳遞至第一級節點的鏈路過長的問題。

本申請實施例提供了一種報告數據處理結果的方法，所述方法包括：