[發明專利]基于分布式系統的內容審核方法和裝置

在審

• 申請號: 202310363311.3
• 申請日: 2023-04-06
• 公開（公告）號: CN116339953A
• 公開（公告）日: 2023-06-27
• 發明（設計）人: 劉永磊
• 申請（專利權）人: 支付寶（杭州）信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 李世喆

1.基于分布式系統的內容審核方法，其中，該方法包括：

得到一個待審核內容所屬的業務場景；

根據預先設置的對應該業務場景的審核流程，生成對應該審核任務的按序排列的多個節點實例；

根據所述業務場景，從各個隊列中選擇一個隊列，并將所述待審核內容的審核任務加入所選擇的該隊列中；

調度各個隊列；

根據當前被調度的隊列中各待審核的審核任務對應的各節點實例之間的排列順序，由分布式系統中的多個服務器從當前被調度的隊列中并發獲取各待審核的審核任務的各節點實例，并審核；

根據一個待審核內容的審核任務對應的所有節點實例的審核結果，得到該待審核內容的審核結果。

2.根據權利要求1所述的方法，其中，所述審核流程包括：由多個審核節點形成的有向無環圖。

3.根據權利要求1所述的方法，其中，所述各個隊列包括：優先級依次降低的實時隊列、高優先級隊列、中優先級隊列以及低優先級隊列中的至少一個，且每一個隊列中包括至少一種業務場景的審核任務；

所述根據所述業務場景從各個隊列中選擇一個隊列，包括：從各個隊列中選擇對應所述業務場景的優先級的隊列；

所述由分布式系統中的多個服務器從當前被調度的隊列中并發獲取各待審核的審核任務的節點實例，包括：分布式系統中的每一個服務器有空閑處理資源時，主動從當前被調度的隊列中拉取節點實例。

4.根據權利要求3所述的方法，其中，所述各個隊列進一步包括：調度優先級最高的第一場景隊列，在第一場景隊列中包括第一業務場景的審核任務；

在所述從各個隊列中選擇對應所述業務場景的優先級的隊列之前，進一步包括：判斷所述待審核內容所屬的業務場景是否為第一業務場景，如果是，則從各個隊列中選擇第一場景隊列，如果否，則執行所述從各個隊列中選擇對應所述業務場景的優先級的隊列；

所述由分布式系統中的多個服務器從當前被調度的隊列中并發獲取各待審核的審核任務的節點實例，進一步包括：

當第一場景隊列中存在待審核的審核任務時，將該待審核的審核任務的節點實例通過消息推送給分布式系統中的至少一個服務器；分布式系統中的至少一個服務器在接收到被推送的消息之后，根據該消息得到第一場景隊列中的待審核的審核任務的節點實例。

5.根據權利要求1所述的方法，其中，所述各個隊列包括：不同業務場景對應的專有隊列，每一個業務場景有專屬于該業務場景的專有隊列；

所述分布式系統中的多個服務器分別對應不同的業務場景；

所述根據所述業務場景從各個隊列中選擇一個隊列，包括：從各個隊列中選擇所述待審核內容所屬的業務場景的專有隊列；

所述由分布式系統中的多個服務器從當前被調度的隊列中并發獲取各待審核的審核任務的節點實例，包括：分布式系統中的一個服務器有空閑處理資源時，主動從該服務器對應的業務場景的專有隊列中拉取節點實例。

6.根據權利要求1至5中任一所述的方法，其中，每一個隊列中的審核任務均對應任務維度和節點維度；

所述將對所述待審核內容的審核任務加入所選擇的該隊列中，包括：在所選擇的隊列的尾部加入所述待審核內容的審核任務；并且，在該審核任務的任務維度中標記等待調度，在該審核任務的節點維度中加入該待審核內容的第一個節點實例；

所述由分布式系統中的多個服務器從當前被調度的隊列中并發獲取各個待審核內容的各節點實例，包括：由分布式系統中的多個服務器分別從當前被調度的隊列中查找被標記為等待調度的至少一個審核任務，對于被查找到的至少一個審核任務，從該審核任務的節點維度中獲取節點實例；

該方法進一步包括：每當一個審核任務的節點維度中的節點實例被服務器獲取并審核之后，刪除該節點維度中的節點實例，根據所述排列順序將與被拉取的該節點實例相鄰的下一級節點實例加入該審核任務的節點維度中；當一個待審核內容的所有節點實例均被服務器獲取并審核之后，將該待審核內容的審核任務標記為已調度。