[發明專利]消費數據處理方法及存儲介質

有效

• 申請號: 202111028477.7
• 申請日: 2021-09-02
• 公開（公告）號: CN113946362B
• 公開（公告）日: 2022-08-16
• 發明（設計）人: 彭朝霞
• 申請（專利權）人: 貝殼找房（北京）科技有限公司
• 主分類號: G06F8/71
• 分類號: G06F8/71;G06F11/30
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 謝志超

本發明提供一種消費數據處理方法及存儲介質，方法包括：讀取配置信息，包括消費數據在第三方平臺的獲取路徑及利用接口調用方式和/或消息流寫入方式的分發方式；獲取分發方式配置信息為消息流寫入方式的至少一個第一業務方，獲取對應的第一消費數據，將第一消費數據發送給對應的第一業務方；和/或，獲取分發方式配置信息為接口調用方式的至少一個第二業務方，獲取對應的第二消費數據，接收第二業務方發送的接口訪問請求，將第二消費數據發送給第二業務方。本發明實施例提供的消費數據處理方法及存儲介質，避免了各個業務方在消費數據獲取過程中代碼的重復開發，簡化了消費數據獲取過程，提高了業務方獲取消費數據的效率。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種消費數據處理方法及存儲介質。

背景技術

信息的發布-訂閱模式，又稱為觀察者模式，在發布-訂閱模式中，主要是兩大塊，就是發布和訂閱，而發布和訂閱流程的完成依賴于對信息的接入、對信息的限流以及對信息的處理等各個階段的充分配合。

現有項目在處理大量信息流的過程中，消息發布-訂閱系統主要用于發布訂閱消息，需要基于不同的消費者各自定制和開發信息的接入、信息的業務處理、信息的限流以及對應的信息處理能力。但是，在整個過程中，除了業務處理，其他的流程都是業務各自重復開發的內容，上述重復開發過程造成了編程過程的冗余，并且還會導致信息處理過程的效率低下。

發明內容

針對現有技術存在的問題，本發明提供一種消費數據處理方法及存儲介質。

本發明提供一種消費數據處理方法，包括：讀取配置信息；其中，所述配置信息包括消費信息源配置信息和分發方式配置信息，所述消費信息源配置信息包括消費數據在第三方平臺的獲取路徑，所述分發方式配置信息包括消息流寫入方式和/或接口調用方式；所述配置信息和業務方一一對應；

獲取所述分發方式配置信息為所述消息流寫入方式的至少一個第一業務方，根據所述消費數據在第三方平臺的獲取路徑獲取對應的第一消費數據，將所述第一消費數據按照預設的消費規則發送給對應的所述第一業務方；和/或，獲取所述分發方式配置信息為所述接口調用方式的至少一個第二業務方，根據所述消費數據在第三方平臺的獲取路徑獲取對應的第二消費數據，接收所述第二業務方發送的用于獲取所述第二消費數據的接口訪問請求，將對應的所述第二消費數據發送給所述第二業務方。

根據本發明提供的一種消費數據處理方法，所述配置信息還包括進程管理配置信息，所述進程管理配置信息包括進程啟動配置信息、進程監控配置信息、進程保護配置信息中的至少一種；其中，所述進程啟動配置信息包括為主進程和子進程設置啟動條件；所述進程保護配置信息包括為主進程設置保護進程和/或配置在監測到子進程異常后重新啟動新的子進程；所述進程監控配置信息包括配置監控主進程和子進程的運行情況，在監控到主進程和/或子進程運行異常時，觸發進程保護；所述方法還包括：根據所述進程管理配置信息進行進程管理。

根據本發明提供的一種消費數據處理方法，所述子進程對應所述第一業務方或所述第二業務方，所述子進程用于根據所述消費數據在第三方平臺的獲取路徑獲取對應的所述第一消費數據或根據所述消費數據在第三方平臺的獲取路徑獲取對應的所述第二消費數據。

根據本發明提供的一種消費數據處理方法，所述主進程利用任務表數據作為拉起所述子進程的數據源并實現對所述子進程的運行情況監控；其中，所述任務表數據包括所述子進程的進程號、業務標識及所述子進程的運行狀態，所述業務標識為所述第一業務方或所述第二業務方的標識。

根據本發明提供的一種消費數據處理方法，所述配置信息還包括限流配置信息，所述限流配置信息用于在所述分發方式配置信息為所述消息流寫入方式時控制寫入速度。