すべてのプロダクト
Search
ドキュメントセンター

Data Management:タスクフローの依存関係チェックノードの設定

最終更新日:Aug 19, 2024

データ管理 (DMS) のタスクオーケストレーション機能を使用すると、タスクフローの依存関係チェックノードを設定できます。 タスクフローが同じタスクフロー内のノードに依存するか、別のタスクフローに依存するかを指定できます。 このトピックでは、タスクフローの依存関係チェックノードを設定する方法について説明します。

シナリオ

  • タスク間フロー依存関係: タスクフローAは、タスクフローBが成功した後にのみ実行されます。

    たとえば、タスクフローAは毎週月曜日の02:00に実行され、推奨モデルをトレーニングします。 タスクフローAは、タスクフローBによって生成された先週 (月曜日から日曜日) のビジネスデータの上で実行されます。

  • 自己依存性: タスクフローAは、その前のサイクルが完了した後にのみ実行される。

    例えば、タスクフローAは、データクレンジングを実行する。 タスクフローAの前のインスタンスが完了した後にのみ実行できます。

使用上の注意

新しいタスクフローには、タスクフローがノードに依存する前に、少なくとも1つの完了したノードが必要です。

  • 手動でトリガーされたタスクフロー: タスクフローの依存関係チェックノードの子孫ノードを選択し、[現在のノードのテスト実行] または [現在のノードからテスト実行を開始] をクリックします。 タスクフローの依存関係チェックノードはスキップされ、テスト実行が成功したことを示すレコードが生成されます。

  • 自動トリガーされたタスクフロー: タスクフローの詳細ページで、image.pngアイコンをクリックし、ドライランを選択します。

    説明

    この場合、成功した自動トリガ記録が生成される。 タスクフローは実行されません。

  • ノードが複数のノードに依存している場合、他のノードに対するノードの依存関係を個別に設定する必要があります。 たとえば、ノードDがノードA、B、およびCに依存する場合、これらの各ノードに対するノードDの依存関係を設定する必要があります。 次の手順では、依存関係を設定する方法について説明します。

手順

  1. DMSコンソールV5.0 にログインします。

  2. 上部のナビゲーションバーで、DTS > データ开発 > タスクオーケストレーション を選択します。

    説明

    DMSコンソールをシンプルモードで使用している場合は、左上隅の2023-01-28_15-57-17.pngアイコンの上にポインターを移動し、[すべての機能] > [DTS] > [データ開発] > [タスクオーケストレーション] を選択します。

  3. 管理したいタスクフローの名前をクリックして、タスクフローの詳細ページに移動します。

    タスクフローの作成方法の詳細については、「概要」をご参照ください。

  4. キャンバスの左側にあるタスクタイプリストで、タスクフローの依存関係の確認ノードをキャンバスの空白領域に移動します。

  5. タスクフローの依存関係の確認 をダブルクリックします。

  6. タスクフローの依存関係の確認ノードの設定ページで、次のパラメーターを設定します。

    パラメーター

    説明

    タスクフロー

    依存関係チェックノードを設定するタスクフロー。 [タスクフロー] フィールドでタスクフローを検索して選択できます。

    説明
    • 現在のタスクフローを選択した場合、タスクフローは前のサイクルの結果に依存します。

    • 別のタスクフローを選択した場合、現在のタスクフローは選択したタスクフローの結果に依存します。

    依存オブジェクト

    依存関係オブジェクトの型。 有効な値:

    • タスクフロー: 現在のタスクフローは別のタスクフローに依存します。

    • 単一ノード: 現在のタスクフローは、タスクフロー内の既存のノードに依存します。

    依存関係の設定

    依存関係チェックの時間設定。 設定には、[開始時間オフセット][終了時間オフセット] が含まれます。

    デフォルトでは、開始時刻と終了時刻は、タスクが実行された時刻に基づいてオフセットされます。

    • 自動トリガーされたタスクフローの場合、業務時間はタスクフローのスケジュールされた実行時間に基づいて計算されます。

    • 手動でトリガーされたタスクフローの場合、業務時間は、タスクフローが手動でトリガーされた時間に基づいて計算されます。

    依存関係の設定例:

    • 例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変数は、タスクが実行される時刻の前日を指定します。

  7. 実行しよう をクリックします。

    • 実行ログの最後の行にstatus SUCCEEDEDが表示された場合、テストの実行は成功です。

    • 実行ログの最後の行にstatus FAILEDが表示された場合、テストの実行は失敗します。

      説明

      テストの実行が失敗した場合は、失敗が発生したノードと失敗の理由を実行ログに表示できます。 次に、ノードの設定を変更して、もう一度お試しください。