E-MapReduce ワークフローでは、DAG に基づくビッグデータジョブの並列実行がサポートされています。Web UI でワークフローを一時停止、停止、再実行し、running ステータスを表示します。
ワークフローの作成
- Alibaba Cloud E-MapReduce コンソールにログインします。
- ページ上部の [データプラットフォーム] タブをクリックします。
- [操作] 列のターゲットプロジェクトの隣にある [ワークフローの設計] をクリックします。 次に [ワークフローの設計] タブを選択します。
- 左側で、操作するクラスターを右クリックして [新規ワークフロー] を選択します。
- [新規ワークフロー] ダイアログボックスで、ワークフローの名前と説明を入力して、ワークフローを実行する E-MapReduce クラスターを選択します。
すでに作成済でプロジェクトと関連付けられた、サブスクリプションまたは従量課金 E-MapReduce クラスターを選択します。 あるいは、クラスターテンプレートを使用して新規クラスターを作成します。
- [OK] をクリックします。
ワークフローの編集
さまざまなタイプのジョブをワークフロー編集キャンバスにドラッグして ジョブインスタンスの順序を曲線で指定します。 ジョブをドラッグしたら、コントロールノードエリアからキャンバスに
[終了] コンポーネントをドラッグします。 これはワークフロー全体が完了したことを示します。
ワークフローの設定
ワークフローの設計 ページの右側で、[設定]をクリックしてワークフローのスケジューリングを設定します。
- 実行場所では、ワークフローを実行する E-MapReduce クラスターを変更します。
- スケジューリングポリシーでは、ワークフローのスケジューリングが有効化されたら、タイムスケジューラーと依存関係の 2 種類からスケジューリングポリシーを選択します。
- タイムスケジューラーでは、ワークフローをスケジューリングするために開始時間と終了時間を設定します。 設定後、設定したスケジュールに従って、システムによってワークフローが実行されます。
- 依存関係では、選択されたプロジェクトから現在の依存ワークフローを選択します。 依存ワークフローが完了したら、現在のワークフローが実行されるようにスケジュールされます。 現在、選択されるワークフローは 1 つだけです。
ワークフローの実行
ワークフローが開発および設定されたら、 右上の [実行] をクリックしてワークフローを実行します。
ワークフローインスタンスの表示と操作
ワークフローが実行されたら、左側の [レコードの表示]タブをクリックしてワークフローインスタンスの running ステータスを表示します。 ワークフローインスタンスの隣にある[詳細の表示]をクリックしてジョブインスタンスの running ステータスを表示します。 ワークフローインスタンスを一時停止、再開、停止、および再実行します。
- ワークフローインスタンスの一時停止によって、ジョブインスタンスの実行は継続されますが、後続のインスタンスは実行されません。[ワークフローの再開] をクリックすると、システムによって後続のジョブの実行が継続されます。
- ワークフローインスタンスの停止によって、すべての実行中のジョブインスタンスが直ちに停止されます。
- ワークフローインスタンスの再実行によって、システムで最初のコンポーネントからワークフローが実行されます。