DataWorks:自動トリガーインスタンス

インテリジェント検索モード

インテリジェント検索を使用すると、クエリを入力するだけで、システムが自動的に解析して必要なインスタンスをフィルタリングします。

1. インテリジェント検索を実行します。

   フィルターボックスの [インテリジェント検索] ボタンをクリックします。表示されるダイアログボックスに、インスタンスタイプでソートなどの検索クエリを入力し、Enter キーを押します。システムは自動的に一致するインスタンスを表示します。

2. 新しいビューを保存します。

   インテリジェント検索の検索条件を再利用する必要がある場合は、検索バーの [未保存のビュー] > [新しいビューとして保存] をクリックします。[ビューの保存] ダイアログボックスで、カスタムの [ビュー名] を入力し、Save をクリックします。その後、ビュー検索バーからこの新しいビューを見つけて使用できます。

   説明

   このビューを使用しなくなった場合は、ビュー検索バーでその名前を見つけます。ビュー名にカーソルを合わせ、右側の [...] アイコンをクリックし、Modify または 削除 を選択します。

3. インテリジェント検索を無効にします。

   フィルター条件を使用して正確な検索を実行する必要がある場合は、Esc キーを押すか、インスタンス操作バーの [インテリジェント検索を無効にする] ボタンをクリックして、インテリジェント検索モードを終了できます。

フィルター条件モード

フィルター条件を使用して、必要な自動トリガーインスタンスを正確に見つけます。

1. シンプルフィルタリング。

   ツールバーで、Search by task name, task ID, or instance ID、スケジューリングリソースグループ、[過去 24 時間以内に報告されたアラート]、In Waiting for Resources State for a Long Period of Time などの複数のフィルター条件を選択して、インスタンスをフィルタリングできます。

2. 高度なフィルタリング。

   フィルターボックスの Filter ボタンをクリックします。その後、Search by task name, task ID, or instance ID、スケジューリングリソースグループ、ランタイム、エンジンインスタンス などの複数の条件を組み合わせて、必要なインスタンスを正確に見つけることができます。

ソートモード

自動トリガーインスタンスリストを、営業日、優先順位、タイミング時間 などのフィールドで昇順または降順にソートできます。正常に実行されたワークフローの場合、内部タスクを [開始時刻]、[終了時刻]、[実行時間] でソートできます。

単一インスタンスの管理

特定の自動トリガーインスタンスを管理するには、リストでそれを見つけ、操作 列のアクションを使用します。次の表に、利用可能なアクションを示します。

複数インスタンスの管理

一度に複数の自動トリガーインスタンスを管理するには、リストでインスタンスを選択します。次に、リストの下部にある一括操作ボタンを使用して、操作の終了、再実行、成功、Change Resource Group、サスペンション (フリーズ)、または 復元 (解凍) を行います。

検索結果からインスタンスのリストをエクスポートするには、まず検索を実行します。次に、インスタンスリストの上にある Export Query Results ボタンをクリックします。Export Query Results ダイアログボックスで、次の情報を確認します：

• Operation Object：現在のフィルター条件に一致するインスタンスの数を表示します。View Filter Conditions をクリックして、特定のフィルターを確認できます。

• Export Method：Export to Local File を選択します。

DAG ページの機能

インスタンスの DAG 詳細ページでは、ノード集約、下流分析、DAG 表示スタイルの調整などの操作を実行できます。

DAG 操作

DAG 詳細ページで、ワークフロー内のインスタンスを右クリックすると、その上流および下流の関係やコードなどの詳細を表示できます。次の操作が利用可能です：

• 親ノードを展開する：現在のノードの上流タスクを表示して、どのノードがそのデータ出力に影響を与えるかを理解します。一度に最大 6 レベルまで、レベルごとに先祖ノードを展開できます。

• 子ノードを展開する：現在のノードの下流タスクを表示して、どのノードがそのデータ出力の影響を受けるかを理解します。一度に最大 6 レベルまで、レベルごとに子孫ノードを展開できます。

• 実行ログの表示：タスクが開始された後、実行ログでその詳細な実行プロセスを表示できます。ログのコアパラメーターの説明については、「付録：実行ログのパラメーター」をご参照ください。

• 診断を実行する：タスクの上流依存関係、スケジューリング時間、スケジューリングリソース、および実行ステータスを確認します。

• コードを表示する：本番環境の現在のノードのコードを表示します。期待どおりでない場合は、ノードの最新バージョンが正常にデプロイされていることを確認してください。

• 編集ノード: DataStudio で現在のノードを開きます。

• 系統を見る：現在のインスタンスのデータリネージを表示します。

• その他：インスタンスの基本プロパティ、操作ログ、タスクコードなどの詳細を表示します。

• 自動トリガーノードの表示：現在のインスタンスが属する自動トリガーノードに関する情報を表示します。

• タスク 360 ページへ移動：データガバナンスセンターに移動して、関連するベースラインやインスタンスの実行ステータスなど、複数のディメンションからタスクの詳細をパノラマ表示し、タスクガバナンスを実行します。詳細については、「タスクのパノラマビューの取得」をご参照ください。

• 操作の終了：実行する必要がなくなったタスクを停止します。タスクのステータスは失敗に設定されます。待ち時間、リソースを待つ、または Running 状態のインスタンスのみを停止できます。

• 再実行：Successful または Failed 状態のタスクを再実行します。タスクが正常に実行された後、未実行の下流タスクをトリガーできます。これは、失敗したノードや見逃したノードを処理するためによく使用されます。

• ダウンストリームで再実行：Successful または Failed 状態のタスクの子孫ノードを再実行します。再実行する下流タスクを選択できます。それらが正常に実行された後、未実行の下流タスクをトリガーできます。これは、データ回復によく使用されます。

• 成功：失敗したタスクのステータスを成功に設定します。これは、失敗したタスクがその下流タスクをブロックしないようにする場合に役立ちます。これは、失敗したノードを処理するためによく使用されます。

• 走り続けた：失敗したタスクを失敗した時点から再開します。タスクに複数の SQL ステートメントが含まれている場合、失敗した特定の SQL ステートメントから再開できます。

  説明

  この操作は、MaxCompute SQL タスクでのみサポートされています。

• Trigger Data Quality Check：タスクにデータ品質ルールが設定されている場合、検証チェックをトリガーできます。

• 緊急操作：緊急操作は一度きりで、ノードの現在の実行にのみ影響します。

  • 削除依存性：現在のノードの依存関係を削除します。これは、上流タスクが失敗したが現在のインスタンスのデータとは無関係である場合に、緊急に上流の依存関係を削除して現在のタスクを実行できるようにするためによく使用されます。

    説明

    タスクコードとデータリネージを確認して、このアクションがデータに影響を与えるかどうかを確認する必要があります。

  • 優先度の変更：インスタンスの優先度はそのベースラインから継承されます。必要に応じてここで優先度をリセットできます。数値が大きいほど優先度が高くなります。

  • 強制再実行：現在のノードを強制的に再実行します。これは、成功、失敗、または未実行状態の自動トリガーインスタンスで実行できます。これは、データ回復によく使用されます。

  • 強制再実行下流：下流タスクを強制的に再実行して、先行する 2 つの業務日のデータを処理します。この操作は、[成功] または [失敗] 状態の自動トリガーインスタンスでのみサポートされており、データ回復によく使用されます。詳細については、「付録：下流の強制再実行」をご参照ください。

    説明

    ワークスペース管理者、テナント管理者、および Alibaba Cloud アカウントのみが下流ノードの強制再実行を開始できます。

  • Clone Instance：実行中のインスタンス (ホストインスタンス) に基づいて新しいクローンインスタンスを作成します。新しいインスタンスは dw_clone_NodeName の形式で命名されます。

    説明

    • ODPS SQL ノードインスタンスのみクローンでき、各インスタンスは一度しかクローンできません。

    • ホストインスタンスとクローンインスタンスの実行ロジック：

      • ホストインスタンスとクローンインスタンスの両方が実行状態になります。ホストインスタンスが先に成功した場合、クローンインスタンスは停止されます。クローンインスタンスが先に成功した場合、ホストインスタンスは停止され、そのステータスは成功に設定されます。

      • 現在のタスクの下流タスクにクローンインスタンスがある場合、下流ノードを再実行してもクローンインスタンスの実行はトリガーされません。

• サスペンション (フリーズ)：インスタンスとその下流インスタンスを実行する必要がない場合にインスタンスを凍結できます。

  重要

  • 上流インスタンスを凍結すると、その下流インスタンスの実行がブロックされます。注意して進めてください。

  • projectname_root ノードはワークスペースのルートノードであるため、操作しないでください。すべての自動トリガーインスタンスはこのノードに依存します。このノードを凍結すると、自動トリガーインスタンスは実行されません。

  • リソースを待つ、待ち時間、または Running (たとえば、ノードコードが実行中またはデータ品質チェックが進行中の場合) の状態にあるインスタンスは凍結できません。

• 復元 (解凍)：凍結状態のインスタンスを凍結解除します。

  • インスタンスがまだ実行されていない場合、上流タスクが完了した後に自動的に実行されます。

  • すべての上流タスクがすでに完了している場合、インスタンスのステータスは失敗に変わります。その後、手動で再実行する必要があります。

  説明

  凍結解除操作は現在のインスタンスにのみ影響します。自動トリガーノードがまだ凍結されている場合、翌日生成されるインスタンスも凍結されます。

インスタンス詳細

インスタンス DAG で、特定のインスタンスを左クリックし、ポップアップウィンドウで View Log Data をクリックするか、詳細を展開 をクリックして、属性、Runtime Log、操作ログ、コード などの詳細情報を表示します。