E-MapReduce ワークフローでは、DAG に基づくビッグデータジョブの並列実行がサポートされています。Web UI でワークフローを一時停止、停止、再実行し、running ステータスを表示します。

ワークフローの作成

  1. Alibaba Cloud E-MapReduce コンソールにログインします。
  2. ページ上部の [データプラットフォーム] タブをクリックします。
  3. [操作] 列のターゲットプロジェクトの隣にある [ワークフローの設計] をクリックします。 次に [ワークフローの設計] タブを選択します。
  4. 左側で、操作するクラスターを右クリックして [新規ワークフロー] を選択します。
  5. [新規ワークフロー] ダイアログボックスで、ワークフローの名前と説明を入力して、ワークフローを実行する E-MapReduce クラスターを選択します。

    すでに作成済でプロジェクトと関連付けられた、サブスクリプションまたは従量課金 E-MapReduce クラスターを選択します。 あるいは、クラスターテンプレートを使用して新規クラスターを作成します。

  6. [OK] をクリックします。

ワークフローの編集

さまざまなタイプのジョブをワークフロー編集キャンバスにドラッグして ジョブインスタンスの順序を曲線で指定します。 ジョブをドラッグしたら、コントロールノードエリアからキャンバスに [終了] コンポーネントをドラッグします。 これはワークフロー全体が完了したことを示します。

ワークフローの設定

ワークフローの設計 ページの右側で、[設定]をクリックしてワークフローのスケジューリングを設定します。

  • 実行場所では、ワークフローを実行する E-MapReduce クラスターを変更します。
  • スケジューリングポリシーでは、ワークフローのスケジューリングが有効化されたら、タイムスケジューラーと依存関係の 2 種類からスケジューリングポリシーを選択します。
    • タイムスケジューラーでは、ワークフローをスケジューリングするために開始時間と終了時間を設定します。 設定後、設定したスケジュールに従って、システムによってワークフローが実行されます。
    • 依存関係では、選択されたプロジェクトから現在の依存ワークフローを選択します。 依存ワークフローが完了したら、現在のワークフローが実行されるようにスケジュールされます。 現在、選択されるワークフローは 1 つだけです。

ワークフローの実行

ワークフローが開発および設定されたら、 右上の [実行] をクリックしてワークフローを実行します。

ワークフローインスタンスの表示と操作

ワークフローが実行されたら、左側の [レコードの表示]タブをクリックしてワークフローインスタンスの running ステータスを表示します。 ワークフローインスタンスの隣にある[詳細の表示]をクリックしてジョブインスタンスの running ステータスを表示します。 ワークフローインスタンスを一時停止、再開、停止、および再実行します。
  • ワークフローインスタンスの一時停止によって、ジョブインスタンスの実行は継続されますが、後続のインスタンスは実行されません。[ワークフローの再開] をクリックすると、システムによって後続のジョブの実行が継続されます。
  • ワークフローインスタンスの停止によって、すべての実行中のジョブインスタンスが直ちに停止されます。
  • ワークフローインスタンスの再実行によって、システムで最初のコンポーネントからワークフローが実行されます。