[發明專利]消費數據的數據處理方法、裝置、計算機設備和存儲介質

在審

• 申請號: 201911002023.5
• 申請日: 2019-10-21
• 公開（公告）號: CN111026725A
• 公開（公告）日: 2020-04-17
• 發明（設計）人: 柯登科
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F16/18
• 分類號: G06F16/18;G06F16/14;G06F9/54
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 劉蔓莉

本申請涉及一種消費數據的數據處理方法、裝置、計算機設備和存儲介質。所述方法包括：接收用于查詢消息中間件中的消費數據的消費軌跡的查詢請求，查詢請求攜帶消費數據的標識；根據消費數據的標識查詢日志文件，得到消費數據的消費軌跡。其中日志文件包括消息生成設備上打印的消息生成日志和消息消費設備上打印的消息消費日志。通過消費數據的標識查詢消息中間件中的各個消費數據對應的日志文件，從而得到各個消費數據的消費軌跡，通過查詢得到的消費軌跡確定各個消費數據的消費狀態和消費結果等等。

技術領域

本申請涉及計算機技術領域，尤其涉及一種消費數據的數據處理方法、裝置、計算機設備和存儲介質。

背景技術

消息隊列已經逐漸成為企業IT系統內部通信的核心手段。它具有低耦合、可靠投遞、廣播、流量控制、最終一致性等一系列功能，成為異步RPC的主要手段之一。當今市面上有很多主流的消息中間件，如ActiveMQ、RabbitMQ，Kafka和RocketMQ等。只支持查看主題下的消息隊列有多少消息被消費，還剩余多少消息沒有被消費等，無法查詢各個消費數據的消費軌跡。

發明內容

為了解決上述技術問題，本申請提供了一種消費數據的數據處理方法、裝置、計算機設備和存儲介質。

第一方面，本申請提供了一種消費數據的數據處理方法，包括：

接收用于查詢消息中間件中的消費數據的消費軌跡的查詢請求，查詢請求攜帶所述消費數據的標識；

根據消費數據的標識查詢日志文件，得到消費數據的消費軌跡。

第二方面，本申請提供了一種消費數據的數據處理裝置，包括：

查詢請求接收模塊，用于接收用于查詢消息中間件中的消費數據的消費軌跡的查詢請求，查詢請求攜帶所述消費數據的標識；

數據查詢模塊，用于根據消費數據的標識查詢日志文件，得到消費數據的消費軌跡。

一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現以下步驟：

接收用于查詢消息中間件中的消費數據的消費軌跡的查詢請求，查詢請求攜帶所述消費數據的標識；

根據消費數據的標識查詢日志文件，得到消費數據的消費軌跡。

一種計算機可讀存儲介質，其上存儲有計算機程序，所述計算機程序被處理器執行時實現以下步驟：

接收用于查詢消息中間件中的消費數據的消費軌跡的查詢請求，查詢請求攜帶消費數據的標識；

根據消費數據的標識查詢日志文件，得到消費數據的消費軌跡。

上述消費數據的數據處理方法、裝置、計算機設備和存儲介質，通過消費數據的標識查詢消息中間件中的各個消費數據對應的日志文件，從而得到各個消費數據的消費軌跡，通過查詢得到的消費軌跡確定各個消費數據的消費狀態和消費結果等等。

在其中一個實施例中，提供了一種消費數據的數據處理方法，包括：

獲取原始消費數據；

為原始消費數據分配對應的標識；

將標識與原始消費數據進行封裝，得到消費數據；

發送消費數據至消息中間件，并打印消費數據，得到消息生成日志。

在其中一個實施例中，提供了一種消費數據的數據處理裝置，包括：

原始數據獲取模塊，用于獲取原始消費數據；

標識分配模塊，用于為原始消費數據分配對應的標識；