ワークフロー機能は、GUI 上でバッチデプロイを効率的にスケジュールするのに役立つ、フルマネージドのワークフロースケジューリング機能です。 ワークフロー機能を使用すると、データウェアハウスを構築し、Realtime Compute for Apache Flink コンソールで開発、スケジューリング、デプロイ、および O&M の統合を実装できます。
ワークフロー機能はパブリックプレビュー段階です。 パブリックプレビュー段階では、サービスレベルアグリーメント (SLA) は保証されません。 詳細については、「Realtime Compute for Apache Flink SLA」をご参照ください。 ワークフロー機能の使用中に質問がある場合は、submit a ticket してください。
ワークフロー機能は、中国 (上海)、中国 (杭州)、中国 (北京)、中国 (深圳)、中国 (張家口)、シンガポール、ドイツ (フランクフルト)、および日本 (東京) リージョンでのみサポートされています。
機能
視覚化された管理: ワークフローを視覚的に作成および管理できます。
スケジューリング: 手動スケジューリングと定期スケジューリングをサポートします。
スケジュール管理: cron 式を使用して複雑なスケジューリングルールを指定できます。
キュー管理: ワークフローとタスクに異なるキューを設定できます。
用語
ワークフロー
ワークフローは、ワークフロー機能に基づいて作成できる有向非巡回グラフ (DAG) です。 ワークフローを作成し、ワークフローでタスクとスケジューリングポリシーを設定して、指定された時点でタスクを実行できます。
タスク
タスクはワークフロー内で実行されます。 各タスクはデプロイに関連付けられている必要があります。
ワークフローインスタンス
ワークフローインスタンスは、ワークフローが実行されるたびに生成されます。
タスクインスタンス
タスクインスタンスは、ワークフローが実行されるたびにタスクによって生成されます。
依存関係
依存関係は、タスク間の関係を示します。 たとえば、タスク A とタスク B がタスク編集ページにタスク A -> タスク B として表示されている場合、タスク A はタスク B が依存するアップストリームタスクです。 タスク B は、タスク B に指定された条件が満たされ、タスク A が完了した後にのみ実行できます。
ワークフローバージョン
ワークフローバージョンは、ワークフローを変更するたびにワークフローに対して生成されます。 たとえば、タスクを追加または削除したり、タスク間の依存関係を変更したりすると、新しいワークフローバージョンが生成されます。