[發明專利]一種調度方法及調度服務器

在審

• 申請號: 202010424467.4
• 申請日: 2020-05-19
• 公開（公告）號: CN111475275A
• 公開（公告）日: 2020-07-31
• 發明（設計）人: 鄧范鑫;蔣龍
• 申請（專利權）人: 北京愛筆科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54;G06Q10/10
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 柳欣

1.一種調度方法，其特征在于，包括：

當確定多個工作任務與同一份數據具有依賴關系時，通過監控任務監控該份數據；

當確定該份數據滿足其對應的監控規則時，執行所述多個工作任務之中上游的工作任務；

下游的工作任務的執行以其上游的工作任務的產出數據滿足該產出數據對應的監控規則作為觸發條件。

2.根據權利要求1所述的調度方法，其特征在于，執行工作任務，具體包括：

解析消息體；所述消息體為當確定該份數據滿足其對應的監控規則時構造的；

判斷所述多個工作任務中是否包含待觸發的工作任務；如果是，則執行所述待觸發的工作任務，更新所述消息體的執行狀態。

3.根據權利要求1所述的調度方法，其特征在于，還包括：

獲得數據監控規則文件，所述數據監控規則文件包括：工作任務與數據的依賴關系和每份數據對應的監控規則。

4.根據權利要求3所述的調度方法，其特征在于，在所述獲得數據監控規則文件之后，所述方法還包括：

將所述數據監控規則文件與規則庫進行比較，當確定所述數據監控規則文件中包含所述規則庫中未包含的新的數據監控規則時，將所述新的數據監控規則添加到所述規則庫中。

5.根據權利要求4所述的調度方法，其特征在于，還包括：

根據所述規則庫所有監控規則的執行結果，確定該份數據對應的最優監控規則；

所述當確定該份數據滿足其對應的監控規則時，執行所述多個工作任務，具體包括：

當確定該份數據滿足其對應的最優監控規則時，執行所述多個工作任務。

6.一種調度服務器，其特征在于，包括：

數據監控模塊，用于當確定多個工作任務與同一份數據具有依賴關系時，通過一份監控任務監控該份數據；任務執行模塊，用于當確定該份數據滿足其對應的監控規則時，執行所述多個工作任務之中上游的工作任務；下游的工作任務的執行以其上游的工作任務的產出數據滿足該產出數據對應的監控規則作為觸發條件。

7.根據權利要求6所述的調度服務器，其特征在于，所述任務執行模塊，具體包括：

解析單元，用于解析消息體；所述消息體為當確定該份數據滿足其對應的監控規則時構造的；

判斷單元，用于判斷所述多個工作任務中是否包含待觸發的工作任務；

執行單元，用于當所述判斷單元判斷的結果為是時，執行所述待觸發的工作任務；

更新單元，用于當所述執行單元對所述待觸發的工作任務執行完成時，更新所述消息體的執行狀態。

8.根據權利要求6所述的調度服務器，其特征在于，還包括：文件接入模塊，用于獲得數據監控規則文件，所述數據監控規則文件包括：工作任務與數據的依賴關系和每份數據對應的監控規則。

9.根據權利要求8所述的調度服務器，其特征在于，還包括：

規則更新模塊，用于將所述數據監控規則文件與規則庫進行比較，當確定所述數據監控規則文件中包含所述規則庫中未包含的新的數據監控規則時，將所述新的數據監控規則添加到所述規則庫中。

10.根據權利要求9所述的調度服務器，其特征在于，還包括：

最優規則確定模塊，用于根據所述規則庫所有監控規則的執行結果，確定該份數據對應的最優監控規則；

所述任務執行模塊，具體用于當確定該份數據滿足其對應的最優監控規則時，執行所述多個工作任務。

11.根據權利要求6-10任一項所述的調度服務器，其特征在于，所述調度服務器為調度服務系統分布式部署的多個調度服務器之一。