[發明專利]用于實施輸出審核數據的可恢復性的專用審核端口

在審

• 申請號: 201980077145.2
• 申請日: 2019-09-25
• 公開（公告）號: CN113168362A
• 公開（公告）日: 2021-07-23
• 發明（設計）人: P·維塞爾;T·墨菲
• 申請（專利權）人: 起元技術有限責任公司
• 主分類號: G06F11/14
• 分類號: G06F11/14;G06F11/30;G06F11/34
• 代理公司: 北京林達劉知識產權代理事務所(普通合伙) 11277
• 代理人: 劉新宇

1.一種通過數據處理系統實施的方法，該數據處理系統用于執行數據流圖，該數據流圖處理表示事務的一個或多個數據記錄，其中，該數據流圖包括多個組件和鏈路，其中，組件表示應用于一個或多個輸入記錄以處理該一個或多個輸入記錄的計算，其中，輸入記錄與表示該事務的一個或多個數據記錄具有指定關系，并且其中，這些鏈路連接這些組件并表示這些組件之間的數據流，該方法包括：

執行包括該多個組件和這些鏈路的數據流圖，其中，該數據流圖的執行包括執行該多個組件中的給定組件，該給定組件包括輸入端口、審核端口和輸出端口；

其中，該輸入端口用于接收這些輸入記錄中的一個或多個輸入記錄，這些輸入記錄與表示該事務的一個或多個數據記錄具有指定關系；

其中，該審核端口用于提供審核數據，該審核數據至少描述該事務的一部分；

其中，該輸出端口用于提供一個或多個輸出記錄；

其中，該多個組件中的至少一個組件被配置用于在執行該給定組件之前執行；

通過具有該多個組件和這些鏈路的數據流圖來處理表示該事務的一個或多個數據記錄，其中，該多個組件中的該至少一個組件對指定由該多個組件中的該至少一個組件處理的這些輸入記錄中的一個或多個輸入記錄的狀態進行保存；

當在該給定組件的執行期間在由該給定組件處理這些輸入記錄中的一個或多個輸入記錄期間發生錯誤時，

將該多個組件中的該至少一個組件的狀態還原到已保存狀態；以及

基于已還原狀態，針對該數據流圖的該給定組件恢復這些審核數據中的至少一些審核數據；

在該審核端口上提供已恢復審核數據中至少描述該事務的該部分的至少一些已恢復審核數據；以及

在該輸出端口上提供該一個或多個輸出記錄。

2.如權利要求1所述的方法，其中，該已恢復審核數據為第一審核數據，該審核端口為第一審核端口，該給定組件為第一組件，并且其中，該方法進一步包括：

以指定的時間間隔將該第一審核數據與在第二組件的第二審核端口上輸出的第二審核數據結合。

3.如權利要求1所述的方法，其中，該給定組件為第一組件，該已恢復審核數據為第一審核數據，并且其中，該方法進一步包括：

在第一數據處理系統上執行該第一組件；

在第二數據處理系統上執行該數據流圖的第二組件；以及

在第三數據處理系統上接收該已恢復審核數據和從該第二組件的第二審核端口輸出的第二審核數據。

4.如權利要求3所述的方法，進一步包括：

將接收到的已恢復審核數據和第二審核數據存儲在存儲器中；以及

根據已存儲審核數據動態生成一個或多個度量。

5.如權利要求1所述的方法，進一步包括：

從第一審核數據和第二審核數據中匯總數據；以及

存儲該經匯總的數據。

6.如權利要求1所述的方法，進一步包括：

通過將該已恢復審核數據分派到特定類別來對該已恢復審核數據進行分類；以及

根據分派到該特定類別的審核數據生成指示用戶與特定活動交互的審核度量。

7.如權利要求1所述的方法，其中，響應于該錯誤的發生，該給定組件在錯誤日志端口上輸出錯誤日志，該錯誤日志包括該多個組件中的該至少一個組件的狀態并指定這些輸入記錄中的哪一個或哪些輸入記錄最后由該多個組件中的該至少一個組件成功處理，其中，該狀態指定這些組件中的哪個組件最后成功地完成處理。

8.如權利要求7所述的方法，其中，該給定組件將該錯誤日志輸出到錯誤處理程序組件，其中，該錯誤處理程序組件基于該錯誤日志向回滾組件傳輸消息，并且其中，該回滾組件使用該消息將該數據流圖的狀態返回到以下狀態：在該狀態下，該多個組件中的至少一個組件正在執行，并且最后由該多個組件中的該至少一個組件成功處理的這些輸入記錄中的一個或多個輸入記錄正在由該多個組件中的該至少一個組件處理。