📄️ 任務生命週期
Skalds 系統中的任務管理涵蓋「建立」、「更新」與「取消」三大核心流程。每個流程皆透過事件驅動機制,結合 Redis、Database 與 Event Queue,確保任務狀態的即時同步與高效調度。以下分別說明各流程細節與設計理念。
📄️ 任務工作者(TaskWorker)
TaskWorker 是 Skalds 系統中負責實際執行任務的核心元件。每個 TaskWorker 以獨立進程運作,具備彈性的生命週期管理、事件驅動參數更新、與 Kafka/Redis 整合能力。開發者可透過繼承基礎類別與註冊自訂處理器,輕鬆擴充與客製化任務邏輯。
📄️ YAML 配置
YAML 配置檔主要用於 Skald Edge 節點(skald_mode="edge"),用來批次定義與註冊多個 TaskWorker。
📄️ CacheMemory
Skalds 系統採用 Redis 8+ 作為核心快取引擎,負責高頻率資料的暫存與同步,顯著提升分散式任務調度的效能與即時性。本文件將說明 Cache Memory 的設計理念、架構、API 介面、典型應用場景、與最佳實踐。
📄️ EventQueue
Skalds 系統中的 EventQueue 是實現模組間鬆耦合、高效能通訊的關鍵元件。它基於 Kafka 3.9.0+,採用發佈/訂閱(Pub/Sub)機制,負責 System Controller、Task Generator(Skald)、Task Worker 之間的事件傳遞與狀態同步。EventQueue 具備高吞吐量、可靠性與彈性擴展能力,是分散式任務調度的核心通訊樞紐。
📄️ Skald
Skald 是 Skalds 分散式任務調度系統的任務生成與調度核心模組,負責任務的初始化、分配、與 TaskWorker 的管理。Skald 現支援三種運作模式:Edge(邊緣節點)、Node(工作節點)與 Single Process(單一行程),可依據應用場景彈性部署,實現高效能、可擴展的任務調度與執行。
🗃️ SystemController
2 items