數據事件發送方法和裝置以及事件處理系統的製作方法

2023-05-31 04:25:56 2

專利名稱：數據事件發送方法和裝置以及事件處理系統的製作方法
技術領域：
本發明一般涉及事件處理領域，特別涉及用於發送數據事件以使 得數據事件與工作流事件相關聯的方法與裝置，以及用於處理工作 流事件和數據事件的系統。
背景技術：
業務監測是業務流程生命周期的重要部分，業務監測使得業務流 程是實時可見的，並能夠及時提供有關業務流程的信息。通常，業 務監測包括分析從業務流程執行過程中發送的事件，提取關心的信 息，並將這些信息進行分析和處理，以便用於後續的數據挖掘中。
在業務流程中，節點可以在進行業務處理的同時發出工作流事 件，來標識業務流程的執行狀況和節點的狀態等。同時，節點還可 以操控業務流程中的數據。
已經有 一 些應用可以用於監測工作流事件，以便客戶掌控業務流 程的進度和狀態。如果整個工作流中的事件與數據都是由一個軟體 系統完成的，通過檢查工作流事件則可以得到工作流中事件與數據 的完整狀態。但是，在有些應用中，工作流的控制與數據的操作分 離了。例如，在一個由銀行控制的申請信用卡的應用中，申請流程 由工作流引擎控制，而對資料庫的操作是由工作流引擎請求現有的
操作資料庫的應用來完成。這樣，工作流事件監測軟體只能得到工 作流引擎發出的工作流事件，而無法得到這些事件所涉及的數據操 作。同樣，通過資料庫日誌，客戶可以得到數據修改的記錄。用戶 只知道數據被修改了 ，而不知道是哪些工作流事件請求了相關數據。 這樣，由於工作流事件缺少了對數據操作的控制或對數據的操作缺 少工作流事件的上下文，客戶無法將工作流事件與數據事件相關聯，不便於後續的事件處理。因此，客戶非常希望能夠同時監測業務流 程中的工作流事件和數據事件並把工作流事件和數據事件關聯。
此外，客戶更加希望在不改變對現有數據的操作的前提下，同時 監測業務流程中的工作流事件和數據事件。
因此，目前存在這樣的問題，即怎樣在不影響已有架構的情況下， 將業務流程中的工作流事件和數據事件進行關聯，以便對業務流程 進行更好地監測或控制。

發明內容
針對以上問題，本發明提供了 一種用於發送數據事件以便工作 流事件與數據事件得以關聯的方法與裝置。
本發明的目的是在業務流程中發送數據事件，以便在不影響已 有架構的情況下，使得業務流程中的工作流事件和數據事件得以關 聯，從而對業務流程進行更好地監測或控制。
根據本發明的第一方面，提供了一種數據事件發送方法，包括
步驟接收由發出工作流事件的節點修改的數據；根據針對修改的 數據的預定義邏輯，得到與工作流事件有關的相關性信息；對修改 的數據和相關性信息格式化，得到數據事件；發送數據事件。
根據本發明的第二方面，提供了一種數據事件發送裝置，包括 步驟接收器，用於接收由發出工作流事件的節點修改的數據；格 式化器，用於根據針對修改的數據的預定義邏輯以得到與工作流事 件有關的相關性信息，以及對修改的數據和相關性信息格式化以得 到數據事件；發送器，用於發送數據事件。
根據本發明的第三方面，提供了一種事件處理系統，包括數 據存儲裝置，用於存儲數據；節點，用於發出工作流事件，並用於 對數據存儲裝置中的數據進行修改；數據事件發送裝置，包括接 收器，用於接收由發出工作流事件的節點修改的數據，格式化器， 用於根據針對修改的數據的預定義邏輯以得到與工作流事件有關的 相關性信息，以及對修改的數據和相關性信息格式化以得到數據事
6件，發送器，用於發送數據事件；以及事件處理裝置，用於將數據 事件與工作流事件相關聯。本發明能夠在不影響現有業務處理架構的情況下，方便地獲取 和發送業務流程中的數據事件，以便業務流程中的工作流事件和數 據事件得以關聯，從而使得客戶能夠對業務流程進行更好地監測或 控制。圖，本發明的其他特徵以及優點將會是顯而易見的。


通過以下結合附圖的說明，並且隨著對本發明的更全面了解，本 發明的其他目的和效果將變得更加清楚和易於理解，其中 圖1是按照本發明的一個實施例的事件處理系統； 圖2是按照本發明的另 一 個實施例的數據事件發送方法的流程圖；圖3是按照本發明的另一個實施例的數據事件發送裝置的方框 圖；以及圖4是示出適於實施本發明的計算機系統的結構的方框圖。 在所有的上述附圖中，相同的標號表示具有相同、相似或相應的 特徵或功能。
具體實施方式
以下將詳細描述本發明的實施方式。在本發明所用的術語中，業務流程是一個或多個節點將輸入轉換 成更有價值的輸出的一組相互關聯的活動。工作流事件是由節點發 出的標識業務流程的執行狀況和節點的狀態等的消息。數據事件是 根據節點修改數據存儲裝置中的數據而生成的消息，可以包括基本 部分和擴展部分，其中基本部分可以包含糹皮^修改的數據，而擴展部分可以包含被修改的數據與工作流事件的相關性信息，以使得數據7事件可以與工作流事件相關聯。圖1是按照本發明的一個實施例的事件處理系統。該實施例的系統包括節點111-113、數據存儲裝置120、數據事件發送裝置 130以及事件處理裝置140。應該注意的是，雖然在該實施例中僅示 出了三個節點，但本發明並不限於此，而是可以應用於任意多個節 點。數據存儲裝置120用於存儲數據。數據存儲裝置120可以是數 據庫，該資料庫可以包括多個表、每個表可以包括多個條目、每個 條目可以包括欄位等。數據存儲裝置120也可以是數據文件，該數 據文件可以存儲二進位碼或ASCII碼形式的數據。節點111 - 113可以直接修改數據存儲裝置120中的數據，例如 可以對資料庫或數據文件中的數據執行增加、刪除、更新等修改操 作，或者可以如圖1所示的那樣通過請求操作資料庫的應用來間接 地修改數據。另外，節點111 - 113還可以在業務流程中發出工作流 事件，以指示業務流程的執行狀況和節,泉的狀態等。數據事件發送裝置130用於執行以下功能從數據存儲裝置接 收由發出工作流事件的節點修改的數據，在一個例子中，當接收到 指示資料庫中的數據被節點111 - 113修改的消息時，數據事件發送 裝置130從數據存儲裝置120讀取該修改的數據，在另一個例子中， 數據事件發送裝置130定期檢測數據存儲裝置120中的數據文件中 的數據是否被節點修改，當檢測到有數據被修改時，數據事件發送 裝置130接收該修改的數據；根據針對修改的數據的預定義邏輯得 到與工作流事件有關的相關性信息，其中預定義邏輯中定義了針對 何種數據設置何種相關性信息，這些相關性信息包括與工作流事件 相關的信息，例如，節點標識符、實例標識符、序列標識符和時間 戳等；將修改的數據連同與工作流事件有關的相關'l"生信息進行格式 化處理，從而得到數據事件；以及，發送該數據事件。事件處理裝置140用於將來自數據事件發送裝置130的數據事 件與來自節點111 -113的工作流事件相關聯，以便用戶能夠在業務流8程的過程中對相互關聯的工作流事件和數據事件進行監測或控制等 處理。圖2是按照本發明的另 一 個實施例的數據事件發送方法的流程 圖。在該實施例中，業務流程以信用卡申請流程為例。在該信用卡 申請流程中的節點可以例如是申請接收節點、審批節點、複查節點 等多種節點。該實施例針對申請節點描述本發明的數據事件發送方 法。通過使用本發明的方法，用戶可以對從申請節點發出的工作流 事件以及與工作流事件關聯的數據事件進行同時監測或控制。在步驟201,獲取與工作流事件有關的相關性信息，該相關性信 息可以例如是節點標識符、實例標識符、序列標識符(諸如時間戳)等。在該實施例的信用卡申請流程中，例如，申請信用卡的動作都 是向申請接收節點(ApplicationReceiver節點)發出的，因此節點標 識符(NodeID)可以用於標識與該節點有關的事件。如果工作流事 件和數據事件具有相同的節點標識符"ApplicationReceiver",也就 是說這些工作流事件和數據事件與同 一 個節點相關，即都與申請接 收節點相關，則可以對與該節點相關的工作流事件和數據事件進行 監測或控制。同時，該監測或控制不會受到與其他節點相關的工作 流事件和數據事件的影響。這樣，可以保證該監測或控制的相對獨 立性。由於在信用卡申請流程中，每 一 個信用卡申請實例都是唯 一 的， 所以每個信用卡申請實例標識符(InstanceID)標識的信用卡申請實 例各不相同。可以利用流水號和字母數字排列等來設置信用卡申請 實例標識符，例如，實例標識符可以是1182261010219。如果工作流 事件和數據事件具有相同的實例標識符"1182261010219",也就是 說這些工作流事件和數據事件與同 一 個信用卡申請實例相關，則可 以對這些與同一個信用卡申請實例相關的工作流事件和數據事件進 行監測或控制。同時，該監測或控制不會受到與其他信用卡申請實 例相關的工作流事件和數據事件的影響。這樣，可以保證該監測或控制的相對獨立性。在該實施例中，申請接收節點通過調用應用來執行向數據存儲 裝置添加數據的操作，將該數據添加到數據存儲裝置的時間可以作 為時間戳，用於將各個事件與時間序列關聯起來。如果已知工作流 事件和數據事件分別具有的時間戳，則可知這些事件的先後關係， 便於對這些事件進行監測或控制。另外，本領域的技術人員可以理 解，除時間戳之外，也可以使用其他序列標識符來標識時間序列。在步驟202,利用在步驟201獲取的相關性信息，設置數據與工 作流事件對應的邏輯。數據存儲裝置可以是一個或多個資料庫。可以針對多個資料庫 中的每一個設置預定義邏輯，也可以更進一步地針對每一個資料庫 中的每一個表分別設置預定義邏輯。數據存儲裝置還可以是一個或 多個數據文件。可以針對多個數據文件中的每一個設置預定義邏輯。在該實施例中，數據存儲裝置是一個資料庫，該資料庫包括諸 如申請人信息表、信用卡信息表的多個表。申請人信息表包括申請人姓名、年齡、電子郵箱等欄位。申請 人信息表與工作流事件對應的邏輯例如可以設置如下向申請人信 息表中的數據添加申請接收節點標識符"ApplicationReceiver"、信用 卡申請實例標識符"1182261010219"、以及時間戳"2007-06-19 13:50:16"。這樣，申請人信息表中的數據與標識符為"ApplicationReceiver，， 的節點、標識符為"1182261010219"的實例、2007年6月19日13點 50分16秒發出的工作流事件相關聯。例如，申請人信息表中的數據 修改可以由標識符為"ApplicationReceiver"的節點所請求，在標識符 為"1182261010219，，的實例中進行，並且與2007年6月19日13點 50分16秒發出的工作流事件密切相關。信用卡信息表可以包括申請人希望申請的信用卡名稱、幣種、 額度等欄位。信用卡信息表與工作流事件對應的邏輯例如可以設置 如下向信用卡信息表中的數據添加申請接收節點標識符10"ApplicationReceiver"、信用卡申請實例標識符"1182261010001"。這樣，信用卡信息表中的數據與節點標識符為 "ApplicationReceiver"的節點發出的、實例標識符為"l 182261010001"的工作流事件相關聯。例如，信用卡信息表中的數據修改可以由標 識符為"ApplicationReceiver，，的節點所請求，也可能在標識符為 "1182261010001"的實例中進4亍，在該例子中，假設信用卡信息表與時間的關係較少，所以沒有 在相關性信息中加入時間戳。本領域的技術人員應該理解，以上的 預定義邏輯設置僅僅是示例性的，而不是必須限制於此。在步驟203,接收指示數據被修改的消息。當申請接收節點修改資料庫中的數據時，資料庫可以通過內部 的消息傳遞機制發送指示數據被修改的消息。例如，資料庫的觸發 器中加入當數據被修改時記錄一個更新標記，形成更新日誌。另一 種可能的方式是，資料庫外部的檢測器可以定期檢測資料庫的變化， 從而當發現資料庫中的數據被修改時，該檢測器發送指示數據被修 改的消息。該檢測器可以在資料庫內部實現，也可以適當的方式在 其他位置處實現。指示數據被修改的消息例如可以包括以下信息修改的數據來自哪一個資料庫或哪一個數據文件，修改的數據來自該資料庫中的 哪一個表(如果修改的數據是存儲在數據文件中的，則該消息可以 指示修改的數據來自哪一個數據文件)。在該實施例中，指示數據 被修改的消息包括修改的數據來自申請接收資料庫中，並來自該 申請接收資料庫中的申請人信息表等。在步驟204,根據在步驟203接收的指示數據被修改的消息，從 申請接收資料庫中的申請人信息表查找並讀取該修改的數據。例如， 該修改的數據可以是向申請人信息表插入的一個新條目，該條目包 括申請人姓名"李明"、年齡"30"歲、電子郵箱 "111^1^30@乂&1100.(;0111.01，，等信息。以下描述了該新條目〈CustomerName〉李明々CustomerName > 3 0<CustomerMail〉 [email protected] <applicationData〉在步驟205,根據修改的數據來自哪個資料庫中的哪個表，查找 針對該數據設置的預定義邏輯。由於在步驟202設置了申請人信息 表與工作流事件對應的邏輯，因此可以查找有關申請人信息表的預 定義邏輯，以便得到與工作流事件相關聯的相關性信息。在步驟206,根據從步驟205得到的針對修改的數據的預定義邏 輯，得到與工作流事件有關的相關性信息。如果查找到存在關於申請人信息表的在預定邏輯，則可以得到 申請人:信息表中的數據與工作流事件關聯的相關性信息。在該實施 例中，相關性信息包括申請接收節點的標識符"ApplicationReceiver"、 實例標識符"1182261010219"、時間戳"2007畫06國19 13:50:16"。所得到 的相關性信息如下ApplicationReceiver 11822610102192007-06-19 13:50:16 </EventHeaderData〉在步驟207,對修改的數據及其相關性信息格式化，得到數據事件。首先可以建立 一 個空的數據事件，然後將在步驟204接收的修 改的數據作為數據事件的基本信息、將在步驟206得到的與工作流 事件相關聯的相關性信息作為數據事件的擴展信息分別填充到數據 事件的適當位置，從而完成數據事件的格式化，得到一個完整的數 據事件。可以理解，在格式化過程中，只要後續的處理中能夠知道數據事件的格式，則可以將數據事件的基本信息和擴展信息按照任何方 式放置，即可以以任何方式對數據事件進行格式化。例如，擴展事 件可以放置在數據事件的頭部，而擴展信息可以放置在基本事件之 後，反之亦然。再例如，擴展事件可以分為兩部分或更多個部分， 分別放置在數據事件的頭部、尾部或其他位置。在步驟208,將得到的數據事件進行發送，以便數據事件能夠與 工作流事件相關聯。在另一個實施例中，數據存儲裝置是一個或多個數據文件，其 中存儲有二進位碼或ASCII碼形式的數據。所以，在步驟202中設 置數據與工作流事件對應的邏輯時，針對各個數據文件而不是針對 資料庫或資料庫中的各表進行設置預定義邏輯。另外，在步驟203 接收指示數據被修改的消息時，由於數據文件自身不具有發送指示 數據被修改的消息的內部消息傳遞機制，所以可以利用檢測器對於 數據文件進行定期檢測，來發現該數據文件中的數據是否有修改。 該檢測器可以在能夠訪問該數據文件的任何位置實現。圖3是按照本發明的另一個實施例的數據事件發送裝置130的 方框圖。該數據事件發送裝置130包括接收器310、格式化器320、 發送器330和邏輯設置器340。接收器310,用於接收由節點修改的數據。在一個實施例中，接 收器310可以從數據存儲裝置接收指示數據被節點修改的消息，然 後根據消息接收修改的數據。在另一個實施例中，接收器310還可 以定期檢測數據存儲裝置中的數據是否被節點修改，當檢測到有數 據被修改時接收修改的數據。其中，數據存儲裝置可以是資料庫和/ 或數據文件。格式化器320,用於根據針對修改的數據的預定義邏輯得到與工 作流事件有關的相關性信息，然後修改的數據作為數據事件的基本 信息、將與工作流事件有關的相關性信息作為數據事件的擴展信息 來進行格式化，從而得到數據事件；發送器330,用於發送所得到的數據事件。13邏輯設置器340,用於獲取與工作流事件有關的相關性信息，利 用所述相關性信息，設置數據與工作流事件對應的邏輯，從而完成 預定義邏輯的設置。其中，相關性信息可以包括節點標識符、實例 標識符、序列標識符以及時間戳中的至少 一個。圖4示意性示出了可以實現根據本發明的實施例的計算設備的 結構方框圖。圖4中所示的計算機系統包括CPU(中央處理單元)401、 RAM(隨 機存取存儲器)402、 ROM(只讀存儲器)403、系統總線404,硬碟控 制器405、鍵盤控制器406、串行接口控制器407、並行接口控制器 408、顯示器控制器409、硬碟410、鍵盤411、串行外部設備412、 並行外部設備413和顯示器414。在這些部件中，與系統總線404 相連的有CPU401、 RAM 402、 ROM 403、硬碟控制器405、鍵盤控 制器406，串行接口控制器407,並行接口控制器408和顯示器控制 器409。硬碟410與硬碟控制器405相連，鍵盤411與鍵盤控制器 406相連，串行外部設備412與串行接口控制器407相連，並行外部 設備413與並行接口控制器408相連，以及顯示器414與顯示器控 制器409相連。圖4中每個部件的功能在本技術領域內都是眾所周知的，並且圖 4所示的結構也是常規的。這種結構不僅用於個人計算機，而且用於 手持設備，如PalmPC、 PDA(個人數字助理)、行動電話等等。在 不同的應用中，例如用於實現包含有根據本發明的客戶端模塊的用可以向圖4中所示的結構添加某些部件，或者圖4中的某些部件可 以被省略。圖4中所示的整個系統由通常作為軟體存儲在硬碟410 中、或者存儲在EPROM或者其他非易失性存儲器中的計算機可讀 指令控制。軟體也可從網絡(圖中未示出)下載。或者存儲在硬碟 410中，或者從網絡下載的軟體可^皮加載到RAM402中，並由CPU 401執行，以便完成由軟體確定的功能。儘管圖4中描述的計算機系統能夠支持根據本發明的方案，但是該計算機系統只是計算機系統的 一 個例子。本領域的技術人員可以 理解，許多其他計算機系統設計也能實現本發明的實施例。
本發明還可以實現為例如由圖4所示計算機系統所使用的計算 機程序產品，其可以包含有用於實現根據本發明的數據事件發送方 法的代碼；其還可以包含有用於實現根據本發明的數據事件發送裝 置的代碼。在使用之前，可以把代碼存儲在其他計算機系統的存儲 器中，例如，存儲在硬碟或諸如光碟或軟盤的可移動的存儲器中， 或者經由網際網路或其他計算機網絡進行下載。
所公開的本發明的方法可以在軟體、硬體、或軟體和硬體的結合 中實現。硬體部分可以利用專用邏輯來實現；軟體部分可以存儲在 存儲器中，由適當的指令執行系統，例如微處理器、個人計算機(PC) 或大型機來執行。
本發明還涉及一種電腦程式產品，該電腦程式產品包括用 於執行如下的代碼接收由發出工作流事件的節點修改的數據；根 據針對修改的數據的預定義邏輯，得到與工作流事件有關的相關'性 信息；對修改的數據和相關性信息格式化，得到數據事件；發送數 據事件。
這樣的電腦程式產品可以存儲在存儲載體中。 雖然已經參考目前考慮到的實施例描述了本發明，但是應該理解 本發明不限於所公開的實施例。相反，本發明旨在涵蓋所附權利要 求的精神和範圍之內所包括的各種修改和等同布置。以下權利要求 的範圍符合最廣泛解釋，以便包含所有這樣的修改及等同結構和功 能。
1權利要求
1. 一種數據事件發送方法，包括接收由發出工作流事件的節點修改的數據；根據針對所述修改的數據的預定義邏輯，得到與所述工作流事件有關的相關性信息；對所述修改的數據和所述相關性信息格式化，得到數據事件；發送所述數據事件。
2. 根據權利要求l的方法，所述接收由節點修改的數據的步驟 包括從數據存儲裝置接收指示數據被節點修改的消息； 根據所述消息，讀取所述修改的數據。
3. 根據權利要求l的方法，所述接收由節點修改的數據的步驟 包括定期檢測數據存儲裝置中的數據是否被節點修改； 當檢測到有數據被修改時，讀取所述修改的數據。
4. 根據權利要求2或3的方法，其中所述數據存儲裝置是數據 庫和/或數據文件。
5. 根據權利要求1的方法，還包括 預先設置所述預定義邏輯。
6. 根據權利要求5的方法，其中所述預先設置所述預定義邏輯 的步驟包括獲取與工作流事件有關的相關性信息；利用所述相關性信息，設置數據與工作流事件對應的邏輯。
7. 根據權利要求6的方法，其中所述相關性信息包括節點標識 符、實例標識符、序列標識符以及時間戳中的至少一個。
8. —種數據事件發送裝置，包括接收器，用於接收由發出工作流事件的節點修改的數據； 格式化器，用於根據針對所述修改的數據的預定義邏輯以得到與所述工作流事件有關的相關性信息，以及對所述修改的數據和所述相關性信息格式化以得到數據事件； 發送器，用於發送所述數據事件。
9. 根據權利要求8的裝置，其中所述接收器還用於 從數據存儲裝置接收指示數據被節點修改的消息； 根據所述消息，讀取所述修改的數據。
10. 根據權利要求8的裝置，其中所述接收器還用於 定期檢觀'j數據存儲裝置中的數據是否被節,S修改；當檢測到有數據被修改時，讀取所述修改的數據。
11. 根據權利要求9或10的裝置，其中所述數據存儲裝置是數 據庫和/或數據文件。
12. 根據權利要求8的裝置，還包括 邏輯設置器，用於預先設置所述預定義邏輯。
13. 根據權利要求12的裝置，其中所述邏輯設置器還用於 獲取與工作流事件有關的相關性信息；利用所述相關性信息，設置數據與工作流事件對應的邏輯。
14. 根據權利要求13的裝置，其中所述相關性信息包括節點標 識符、實例標識符、序列標識符以及時間戳中的至少一個。
15. —種事件處理系統，包括 數據存儲裝置，用於存儲數據；節點，用於發出工作流事件，並用於對所述數據存儲裝置中的 數據進行修改；數據事件發送裝置，包括接收器，用於接收由發出工作流事件的節點修改的數據， 格式化器，用於根據針對所述修改的數據的預定義邏輯以得到與所述工作流事件有關的相關性信息，以及對所述修改的數據和所述相關性信息格式化以得到數據事件，發送器，用於發送所述數據事件；以及事件處理裝置，用於將所述數據事件與所述工作流事件相關聯。
16. 根據權利要求15的系統，其中所述接收器還用於 從數據存儲裝置接收指示數據被節點修改的消息； 根據所述消息，讀取所述修改的數據。
17. 根據權利要求15的系統，其中所述接收器還用於 定期檢測數據存儲裝置中的數據是否被節,泉修改；當檢測到有數據被修改時，讀取所述修改的數據。
18. 根據權利要求16或17的系統，其中所述數據存儲裝置是數 據庫和/或數據文件。
19. 根據權利要求15的系統，其中所述數據事件發送裝置還包括邏輯設置器，用於預先設置所述預定義邏輯。
20. 根據權利要求19的系統，其中所述邏輯設置器還用於 獲取與工作流事件有關的相關性信息；利用所述相關性信息，設置數據與工作流事件對應的邏輯。
21. 根據權利要求20的系統，其中所述相關性信息包括節點標 識符、實例標識符、序列標識符以及時間戳中的至少一個。
全文摘要
公開了一種數據事件發送方法和裝置以及事件處理系統。該方法包括步驟接收由發出工作流事件的節點修改的數據；根據針對修改的數據的預定義邏輯，得到與工作流事件有關的相關性信息；對修改的數據和相關性信息格式化，得到數據事件；發送數據事件。本方法能夠在不影響現有業務處理架構的情況下，獲取和發送業務流程中的數據事件，以便業務流程中的工作流事件和數據事件得以關聯。
文檔編號G06Q10/00GK101520861SQ20081008093
公開日2009年9月2日 申請日期2008年2月29日 優先權日2008年2月29日
發明者M·斯塔基, 豔 周, 成 張, 軼 車 申請人:國際商業機器公司