本トピックでは、EMR Workflow のビジュアルインターフェイスを使用してワークフローとタスクを管理する方法について説明します。
前提条件
システムロールの権限付与が完了していること。詳細については、「EMR Workflow のロール権限付与」をご参照ください。
EMR on ECS でクラスターまたはクラスターテンプレートを作成済みであること。詳細については、「クラスターの作成」または「クラスターテンプレートの作成」をご参照ください。
サポートされているクラスタータイプは、データレイク、Hadoop、カスタムです。
ステップ 1:クラスターのバインドとワークスペースの関連付け
Alibaba Cloud アカウント (メインアカウント) または RAM ユーザーで EMR コンソールにログインします。
左側のナビゲーションウィンドウで、[EMR Studio] > [ワークフロー] を選択します。
ワークフローページで、スケジューリングリソースグループ をクリックします。
クラスターまたはクラスターテンプレートをバインドします。
スケジューリングリソースグループ ページで、対象の実行クラスターを見つけ、[操作] 列の クラスターの関連付け をクリックします。
EMR クラスター / クラスターテンプレートの関連付け ダイアログボックスで、対象のクラスターまたはクラスターテンプレートを見つけ、[操作] 列の 関連付け をクリックします。
ダイアログボックスで vSwitch とセキュリティグループを選択し、OK をクリックします。
説明クラスターのバインドには 5〜10 分かかります。
(任意) ワークスペースを関連付けます。
説明EMR Workflow を初めてアクティベートすると、無料のデフォルト実行クラスターが提供されます。このデフォルトクラスターは、作成時に自動的に
defaultワークスペースに関連付けられます。デフォルトの実行クラスターが要件を満たさない場合は、有料の実行クラスターを購入できます。有料の実行クラスターの仕様と課金の詳細については、「実行クラスターの課金」をご参照ください。有料の実行クラスターは、手動でワークスペースに関連付ける必要があります。スケジューリングリソースグループ ページで、ワークスペースの関連付け をクリックします。
ワークスペースの関連付け ダイアログボックスで、使用するワークスペースを見つけ、[操作] 列の Associate をクリックします。
確認ダイアログボックスで、OK をクリックします。
ステップ 2:プロジェクトの作成
ワークフローページの ワークスペース タブで、対象のワークスペースを見つけ、[操作] 列の コンソール をクリックします。
Project Management ページで、Create Project をクリックします。
ダイアログボックスで Project Name を入力し、OK をクリックします。
ステップ 3:ワークフローの作成
Project Management ページで、新しいプロジェクトの名前をクリックします。
左側のナビゲーションウィンドウで、 を選択します。
Workflow Definition ページで、Create Workflow をクリックします。
Create Workflow ページで、SHELL ノードをキャンバスにドラッグします。
本トピックでは、SHELL ノードタイプを例として使用します。ノードタイプの詳細については、「ノードタイプ」をご参照ください。
ダイアログボックスでパラメーターを設定し、OK をクリックします。
次の表に設定例を示します。他のパラメーターはデフォルト値のままにすることができます。パラメーターの詳細については、「SHELL」をご参照ください。手動タスクを関連付けるには、Associate Manual Task スイッチをオンにし、既存の手動タスクを選択します。
パラメーター
説明
Node Name
ノードのカスタム名。例:
shell。Script
カスタムの Shell プログラム。
ワークフローを保存します。
キャンバスの右上隅にある Save をクリックします。
ダイアログボックスで Workflow Name を入力し、OK をクリックします。
ステップ 4:ワークフローの実行
Workflow Definition ページで、対象のワークフロー定義を見つけ、[操作] 列の 実行 をクリックします。
ダイアログボックスで、スケジューリングリソースグループ ドロップダウンリストから実行クラスターを選択し、OK をクリックします。
ステップ 5:タスクインスタンスのログ表示
左側のナビゲーションウィンドウで、Instance O&M > Workflow Instance を選択して、ワークフローインスタンスのステータスを表示します。
左側のナビゲーションバーで、Instance O&M > Task Instance を選択します。
Task Instance ページで、対象のタスクインスタンスを見つけ、[操作] 列の View Logs をクリックします。
(任意) ステップ 6:ワークフローのスケジューリング
Workflow Definition ページで、対象のワークフロー定義を見つけ、操作 列の Configure Scheduling Time をクリックします。
ダイアログボックスでパラメーターを設定し、OK をクリックします。
Time Period:ワークフローはこの期間内にのみスケジュールどおりに実行されます。この範囲外では、スケジュールは新しいワークフローインスタンスを生成しません。
Configure Scheduling Time:ワークフローを実行するタイミングを選択します。
対象のワークフローの Schedule Status 列で、スイッチをオンにします。