[發(fā)明專利]消費數(shù)據(jù)處理方法及存儲介質

有效

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

1.一種消費數(shù)據(jù)處理方法，其特征在于，包括：

讀取配置信息；其中，所述配置信息包括消費信息源配置信息和分發(fā)方式配置信息，所述消費信息源配置信息包括消費數(shù)據(jù)在第三方平臺的獲取路徑，所述分發(fā)方式配置信息包括消息流寫入方式和/或接口調用方式；所述配置信息和業(yè)務方一一對應；

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

所述配置信息還包括限流配置信息，所述限流配置信息用于在所述分發(fā)方式配置信息為所述消息流寫入方式時控制寫入速度；所述限流配置信息包括配置向令牌桶投遞令牌的速度；所述將所述第一消費數(shù)據(jù)按照預設的消費規(guī)則發(fā)送給對應的所述第一業(yè)務方，具體包括：請求從所述令牌桶取走令牌，若取到所述令牌，則將所述第一消費數(shù)據(jù)按照預設的消費規(guī)則發(fā)送給對應的所述第一業(yè)務方，若未取到所述令牌，則轉到所述請求從所述令牌桶取走令牌。

2.根據(jù)權利要求1所述的消費數(shù)據(jù)處理方法，其特征在于，所述配置信息還包括進程管理配置信息，所述進程管理配置信息包括進程啟動配置信息、進程監(jiān)控配置信息、進程保護配置信息中的至少一種；其中，所述進程啟動配置信息包括為主進程和子進程設置啟動條件；所述進程保護配置信息包括為主進程設置保護進程和/或配置在監(jiān)測到子進程異常后重新啟動新的子進程；所述進程監(jiān)控配置信息包括配置監(jiān)控主進程和子進程的運行情況，在監(jiān)控到主進程和/或子進程運行異常時，觸發(fā)進程保護；

所述方法還包括：根據(jù)所述進程管理配置信息進行進程管理。

3.根據(jù)權利要求2所述的消費數(shù)據(jù)處理方法，其特征在于，所述子進程對應所述第一業(yè)務方或所述第二業(yè)務方，所述子進程用于根據(jù)所述消費數(shù)據(jù)在第三方平臺的獲取路徑獲取對應的所述第一消費數(shù)據(jù)或根據(jù)所述消費數(shù)據(jù)在第三方平臺的獲取路徑獲取對應的所述第二消費數(shù)據(jù)。

4.根據(jù)權利要求3所述的消費數(shù)據(jù)處理方法，其特征在于，所述方法還包括：

所述主進程利用任務表數(shù)據(jù)作為拉起所述子進程的數(shù)據(jù)源并實現(xiàn)對所述子進程的運行情況監(jiān)控；其中，所述任務表數(shù)據(jù)包括所述子進程的進程號、業(yè)務標識及所述子進程的運行狀態(tài)，所述業(yè)務標識為所述第一業(yè)務方或所述第二業(yè)務方的標識。

5.根據(jù)權利要求1所述的消費數(shù)據(jù)處理方法，其特征在于，所述配置信息還包括：

在所述分發(fā)方式配置信息為所述接口調用方式時，配置所述消費數(shù)據(jù)在數(shù)據(jù)庫的存儲規(guī)則；所述存儲規(guī)則包括數(shù)據(jù)存儲時間和/或數(shù)據(jù)存儲的上限；

和/或，所述配置信息還包括業(yè)務重試配置信息，所述業(yè)務重試配置信息包括配置所述第二業(yè)務方在所述接口訪問請求失敗后重新發(fā)起所述接口訪問請求的信息。

6.根據(jù)權利要求5所述的消費數(shù)據(jù)處理方法，其特征在于，所述方法還包括：當業(yè)務消費出問題時，根據(jù)消費數(shù)據(jù)在數(shù)據(jù)庫中存儲的時間節(jié)點和/或偏移量進行重新消費；

和/或，當本地存儲數(shù)據(jù)丟失時，自動根據(jù)所述消費信息源配置信息從kafka數(shù)據(jù)源節(jié)點的偏移量同步獲取數(shù)據(jù)。

7.根據(jù)權利要求1所述的消費數(shù)據(jù)處理方法，其特征在于，所述配置信息還包括報警規(guī)則配置信息；

所述方法還包括：根據(jù)所述報警規(guī)則配置信息進行報警處理，并將報警信息發(fā)送到對應的所述第一業(yè)務方或所述第二業(yè)務方。

8.一種非暫態(tài)計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該計算機程序被處理器執(zhí)行時實現(xiàn)如權利要求1至7任一項所述消費數(shù)據(jù)處理方法的步驟。