[發明專利]訂單變更過程整合方法、提取方法、整合裝置和提取裝置

在審

• 申請號: 202011026446.3
• 申請日: 2020-09-25
• 公開（公告）號: CN112162904A
• 公開（公告）日: 2021-01-01
• 發明（設計）人: 黃國榮
• 申請（專利權）人: 同程網絡科技股份有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F16/27;G06F16/22;G06F16/245;G06F16/248
• 代理公司: 暫無信息
• 代理人: 暫無信息

本申請涉及計算機的領域，尤其是涉及一種訂單變更過程整合方法、提取方法、整合裝置和提取裝置，其整合方法包括將各個數據庫中的binlog日志添加到隊列中；對隊列中的binlog日志進行消費；將經過消費的binlog日志存到分布式開源數據庫中。將所有binlog日志添加到隊列中，由隊列對binlog日志進行消費，將binlog日志存到分布式開源數據庫中，使所有數據庫生成的binlog日志均位于同一個分布式開源數據庫中，實現對binlog日志的整合。相關人員無需在多個系統之間進行切換，無需對冗余日志進行過濾。方便相關人員對binlog日志進行查詢、提取或調用。本申請具有有助于提高訂單問題定位的效率的效果。

技術領域

本申請涉及計算機的領域，尤其是涉及一種訂單變更過程整合方法、提取方法、整合裝置和提取裝置。

背景技術

隨著業務系統越來越復雜，一個業務流程需要涉及多個系統間的調用才能完成。而業務復雜度的增加也使得訂單出現問題的幾率增大。當訂單出現問題后，需要對訂單問題進行定位，而后便可得知問題的源頭。

在相關技術中，訂單問題定位通常是通過在業務系統中提前記錄許多冗余的日志。訂單問題定位過程中，在各個系統間進行切換，過濾掉冗余日志，得到有用的日志。

針對上述中的相關技術，發明人認為開發人員需要在多個系統中切換查找相關日志，且冗余日志較多，步驟繁瑣，過程復雜，降低了訂單問題定位的效率。

發明內容

為了提高訂單問題定位的效率，本申請提供一種訂單變更過程整合方法、提取方法、整合裝置和提取裝置。

第一方面，本申請提供的一種訂單變更過程整合方法，采用如下的技術方案：

一種訂單變更過程整合方法，包括將各個數據庫中的binlog日志添加到隊列中；對所述隊列中的binlog日志進行消費；將經過消費的binlog日志存到分布式開源數據庫中。

通過采用上述技術方案，當訂單出現問題時，與該訂單相關的數據庫中會生成對應的binlog日志，binlog日志中記載有該訂單的變更過程。將所有生成的binlog日志收集到隊列中，對隊列中的binlog日志進行消費，使binlog日志被添加到分布式開源數據庫中。當相關人員需要對某個訂單問題進行定位時，由于所有訂單變更過程的binlog日志均位于分布式開源數據庫中，因此相關人員在分布式開源數據庫中查詢均可。無需在多個系統之間進行切換，查找相關的binlog日志。同樣也無需過濾冗余日志，操作簡單，方便快捷，有助于提高訂單問題定位的效率。

優選的，所述分布式開源數據庫包括多個數據表，每個所述數據表對應一個所述數據庫，每個所述數據表分別設有對應的數據表名；每個所述數據表中包括多個分區，每個所述分區分別設有對應的分區號；所述binlog日志存儲到對應所述數據表中的對應所述分區中。

通過采用上述技術方案，在數據表中預設若干分區，有助于使數據分布的更均勻。避免出現熱點數據，減少自動分區時產生的I/O消耗，從而提高分布式開源數據庫使用的整體性能。

優選的，所述分區號根據所述binlog日志中的訂單號計算hash值再取余生成。

通過采用上述技術方案，由于訂單號是固定的，因此分區號也是固定的。在向某個數據表中添加binlog日志時，不同訂單號的相關binlog日志被分配到不同的分區中。使各個分區中的binlog日志量相對均勻，有助于提高分布式開源數據庫的性能，從而有助于提高數據的查詢速度和提取速度，加快訂單問題定位的效率。

優選的，根據所述數據表名、所述分區號和訂單號構成所述分布式開源數據庫的RowKey；根據所述隊列中的offset以字符串形式加上更新類型作為所述數據表的列名；將所述binlog日志的rowData轉換成json字符串作為存入所述分布式開源數據庫的value；將轉換后的所述binlog日志的rowData存入對應的所述數據表中。