SchedulerX の用語は、システムアーキテクチャにおける役割別に整理されています。
リソースの構成
名前空間
SchedulerX は名前空間を使用してリソースを分離します。各名前空間は論理的に独立しているため、単一の Alibaba Cloud アカウントですべての名前空間を管理しつつ、開発、ステージング、本番などの環境を分離できます。
AppGroup
AppGroup (アプリケーショングループ) はアプリケーションにマッピングされ、ワーカーに関連付けられます。AppGroup は、異なるアプリケーションに属するジョブを分離します。たとえば、注文処理ジョブとレポート作成ジョブを別々の AppGroup に配置することで、それぞれを独立した状態に保つことができます。
スケジューリング単位
SchedulerX のジョブは、ジョブ、ジョブインスタンス、タスクの 3 階層で構成されます。
ジョブ
└── ジョブインスタンス (トリガーごとに 1 つ)
└── タスク (並列実行のサブユニット)ジョブ
ジョブは、SchedulerX における最小のスケジューリング可能な単位です。
ジョブインスタンス
システムがジョブをトリガーするたびに、ジョブインスタンスを生成します。1 つのジョブは、時間の経過とともに多数のジョブインスタンスを生成できます (トリガーイベントごとに 1 つ)。
タスク
タスクは、並列コンピューティング、メモリグリッド、またはグリッドコンピューティングモードでシステムがmapメソッドを呼び出すときに作成されるサブユニットです。
オーケストレーション
ワークフロー
ワークフローは、複数のジョブを組み合わせて有向非巡回グラフ (DAG) を構築します。ワークフロー内の各ノードはジョブを表し、エッジは実行順序と依存関係を定義します。
DAG
DAG は有向非巡回グラフ (Directed Acyclic Graph) の略で、サイクルのない有向エッジのグラフです。SchedulerX では、すべてのワークフローが DAG として表現されます。これにより、ジョブの依存関係が予測可能で非循環的な順序で解決されることが保証されます。
時間の概念
スケジュール時刻
スケジュール時刻は、ジョブインスタンスが実行される予定の時刻です。JobProcessor は、context.getScheduleTime() でスケジュール時刻を取得できます。
時系列データ
SchedulerX は、トリガー時刻とジョブが処理するデータ期間を切り離すことで、時系列データの処理をサポートします。ジョブを作成する際にタイムオフセットを設定すると、ジョブは実行時刻とは異なる時点のデータを処理します。
例： ジョブが毎日 00:30 にトリガーされますが、前日の 23:30 に更新されたデータを処理する必要がある場合、タイムオフセットを 1 時間に設定します。ジョブは 00:30 にトリガーされますが、context.getDataTime() は前日の 23:30 を返すため、コード内で正しいデータウィンドウを取得できます。