データ管理 (DMS) のタスクオーケストレーション機能を使用すると、タスクフローの依存関係チェックノードを設定できます。 タスクフローが同じタスクフロー内のノードに依存するか、別のタスクフローに依存するかを指定できます。 このトピックでは、タスクフローの依存関係チェックノードを設定する方法について説明します。
シナリオ
タスク間フロー依存関係: タスクフローAは、タスクフローBが成功した後にのみ実行されます。
たとえば、タスクフローAは毎週月曜日の02:00に実行され、推奨モデルをトレーニングします。 タスクフローAは、タスクフローBによって生成された先週 (月曜日から日曜日) のビジネスデータの上で実行されます。
自己依存性: タスクフローAは、その前のサイクルが完了した後にのみ実行される。
例えば、タスクフローAは、データクレンジングを実行する。 タスクフローAの前のインスタンスが完了した後にのみ実行できます。
使用上の注意
新しいタスクフローには、タスクフローがノードに依存する前に、少なくとも1つの完了したノードが必要です。
手動でトリガーされたタスクフロー: タスクフローの依存関係チェックノードの子孫ノードを選択し、[現在のノードのテスト実行] または [現在のノードからテスト実行を開始] をクリックします。 タスクフローの依存関係チェックノードはスキップされ、テスト実行が成功したことを示すレコードが生成されます。
自動トリガーされたタスクフロー: タスクフローの詳細ページで、アイコンをクリックし、ドライランを選択します。
説明この場合、成功した自動トリガ記録が生成される。 タスクフローは実行されません。
ノードが複数のノードに依存している場合、他のノードに対するノードの依存関係を個別に設定する必要があります。 たとえば、ノードDがノードA、B、およびCに依存する場合、これらの各ノードに対するノードDの依存関係を設定する必要があります。 次の手順では、依存関係を設定する方法について説明します。
手順
DMSコンソールV5.0 にログインします。
上部のナビゲーションバーで、 を選択します。
説明DMSコンソールをシンプルモードで使用している場合は、左上隅のアイコンの上にポインターを移動し、
を選択します。管理したいタスクフローの名前をクリックして、タスクフローの詳細ページに移動します。
タスクフローの作成方法の詳細については、「概要」をご参照ください。
キャンバスの左側にあるタスクタイプリストで、タスクフローの依存関係の確認ノードをキャンバスの空白領域に移動します。
タスクフローの依存関係の確認 をダブルクリックします。
タスクフローの依存関係の確認ノードの設定ページで、次のパラメーターを設定します。
パラメーター
説明
タスクフロー
依存関係チェックノードを設定するタスクフロー。 [タスクフロー] フィールドでタスクフローを検索して選択できます。
説明現在のタスクフローを選択した場合、タスクフローは前のサイクルの結果に依存します。
別のタスクフローを選択した場合、現在のタスクフローは選択したタスクフローの結果に依存します。
依存オブジェクト
依存関係オブジェクトの型。 有効な値:
タスクフロー: 現在のタスクフローは別のタスクフローに依存します。
単一ノード: 現在のタスクフローは、タスクフロー内の既存のノードに依存します。
依存関係の設定
依存関係チェックの時間設定。 設定には、[開始時間オフセット] と [終了時間オフセット] が含まれます。
デフォルトでは、開始時刻と終了時刻は、タスクが実行された時刻に基づいてオフセットされます。
自動トリガーされたタスクフローの場合、業務時間はタスクフローのスケジュールされた実行時間に基づいて計算されます。
手動でトリガーされたタスクフローの場合、業務時間は、タスクフローが手動でトリガーされた時間に基づいて計算されます。
依存関係の設定例:
例1: 毎日07:00に開始する予定のタスクフローAは、毎日07:00に開始する予定のタスクフローBの最後の予定サイクルに依存します。 依存関係チェック設定では、タスクフローAの開始時間オフセットは07:00のままで、終了時間オフセットは1日増加します。
説明最後のスケジュールされたサイクルは、タスクフローの最後の実行が完了すると終了します。 スケジュールされた実行時間の詳細については、「タスクフローの設定」トピックの「タスクフローのスケジューリングプロパティの設定」をご参照ください。
例2: 毎日08:00に開始するようにスケジュールされているタスクフローAは、毎日07:00に開始するようにスケジュールされているタスクフローBの最後のスケジュールされたサイクルに依存します。 依存関係チェック設定では、タスクフローAの開始時間オフセットは08:00のままで、終了時間オフセットは1日増加し、1時間減少します。
例3: 毎日08:10に開始するようにスケジュールされているタスクフローAは、毎日07:00に開始するようにスケジュールされているタスクフローBの最後のスケジュールされたサイクルに依存します。 依存関係チェック設定では、タスクフローAの開始時間オフセットは08:10のままで、終了時間オフセットは1日増加し、1時間10分減少します。
説明設定ページの上部で、[プレビュー] をクリックします。 [時間のプレビュー] ダイアログボックスで、タスクフローの時間値が期待どおりに設定されているかどうか、およびノードが正常に実行されるかどうかを確認します。
データベースインスタンスのポリシーの確認
タスクフローのチェックポリシー。 有効な値:
最後のラウンドの成功: 現在のタスクフローが依存する最後のノードの実行が成功した後、タスクフローは依存関係チェックに合格します。
All Round Succeeded: タスクフローは、現在のタスクフローが依存するすべてのノードの実行が成功した後にのみ、依存関係チェックに合格します。
指定されたラウンドの成功: 現在のタスクフローが依存する指定されたノードの実行が成功した後、タスクフローは依存関係チェックに合格します。
説明手動でトリガーされたタスクフローでは、手動でトリガーされたノードのみがチェックされます。
自動トリガータスクフローでは、自動トリガーノードのみがチェックされます。
たとえば、タスクフローAは手動でトリガーされ、自動的にトリガーされませんでした。 タスクフローaで依存関係チェックを実行すると、テストの実行は成功しますが、タスクフローAは自動的にトリガーされません。
チェックタイプ
タスクフローの開始時間と終了時間を含む、予想されるチェック時間のタイプ。 有効な値:
Run At: 開始時刻と終了時刻は、タスクが実行された時刻に基づいてオフセットされます。
営業日: 開始時刻と終了時刻は、bizdate時刻変数に基づいてオフセットされます。 bizdate time変数は、タスクが実行される時刻の前日を指定します。
実行しよう をクリックします。
実行ログの最後の行に
status SUCCEEDED
が表示された場合、テストの実行は成功です。実行ログの最後の行に
status FAILED
が表示された場合、テストの実行は失敗します。説明テストの実行が失敗した場合は、失敗が発生したノードと失敗の理由を実行ログに表示できます。 次に、ノードの設定を変更して、もう一度お試しください。