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

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

インテリジェント検索は、クエリを自動的に解析して、一致するインスタンスをフィルタリングします。

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

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

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

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

   説明

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

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

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

フィルター条件モード

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

1. 簡易フィルタリング。

   ツールバーでは、タスク名 / タスク ID / インスタンス ID、リソースグループのスケジューリング、[過去 24 時間以内に報告されたアラート]、長時間のリソース待機 などの複数のフィルター条件を選択して、インスタンスをフィルタリングできます。

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

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

ソートモード

自動トリガーインスタンスのリストを、データタイムスタンプ、優先度、実行時刻 などのフィールドで昇順または降順に並べ替えることができます。正常に実行されたワークフローについては、内部タスクを [開始時間]、[終了時間]、[実行時間] で並べ替えることができます。

単一インスタンスの管理

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

複数インスタンスの管理

複数の自動トリガーインスタンスを一度に管理するには、リストでインスタンスを選択します。次に、リストの下部にある一括操作ボタンを使用して、実行の終了、再実行、設定が完了しました。、リソースグループの編集、一時停止 (フリーズ)、または 復元 (解凍) を実行します。

一括再実行の確認ダイアログボックスには、最新の構成で再実行 スイッチがあり、デフォルトでオフになっています。このスイッチをオンにすると、インスタンスの次のプロパティが最新のタスク設定に更新されます：コンピューティングリソース、リソースグループ、CU、優先度、イメージ、スケジューリングタイプ、再実行ポリシー、タイムアウト定義、所有者、タグ、および DQC 設定。ノード設定を変更した後にこのスイッチをオンにします。インスタンスプロパティを手動で変更した場合は、それらのプロパティがリセットされる可能性があるため、このスイッチをオンにしないでください。このスイッチのオン/オフに関わらず、ノードコードは再実行のたびに常に最新バージョンを使用します。

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

• [操作対象]：現在のフィルター条件に一致するインスタンスの数を表示します。{objName} のフィルター条件の表示 をクリックして、特定のフィルターを確認できます。

• [エクスポート方式]：ローカルへのエクスポート を選択します。

DAG ページの機能

DAG 詳細ページでは、ノードの集約、上流および下流の依存関係の分析、DAG 表示スタイルの調整ができます。

DAG アクション

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

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

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

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

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

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

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

• [データリネージの表示]：現在のインスタンスのデータリネージを表示します。

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

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

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

• [実行の終了]: 実行する必要がなくなったタスクを停止します。タスクステータスは失敗になります。待機時間、リソース待機中、または 実行中 の状態にあるインスタンスのみを停止できます。

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

  確認ダイアログボックスでは、最新の構成で再実行 スイッチはデフォルトでオフになっています。このスイッチをオンにすると、インスタンスの次のプロパティが最新のタスク設定に更新されます：コンピューティングリソース、リソースグループ、CU、優先度、イメージ、スケジューリングタイプ、再実行ポリシー、タイムアウト定義、所有者、タグ、および DQC 設定。ノード設定を変更した後にこのスイッチをオンにします。インスタンスプロパティを手動で変更した場合は、それらのプロパティがリセットされる可能性があるため、このスイッチをオンにしないでください。このスイッチのオン/オフに関わらず、ノードコードは再実行のたびに常に最新バージョンを使用します。

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

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

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

  説明

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

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

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

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

    説明

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

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

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

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

    説明

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

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

    説明

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

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

      • ホストインスタンスとクローンインスタンスは、どちらも実行中です。ホストインスタンスが先に成功した場合、クローンインスタンスは停止されます。クローンインスタンスが先に成功した場合、ホストインスタンスは停止され、そのステータスは成功に設定されます。

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

• [一時停止 (フリーズ)]：インスタンスとその下流インスタンスを実行する必要がない場合にインスタンスをフリーズできます。

  重要

  • 上流インスタンスをフリーズすると、その下流インスタンスの実行がブロックされます。慎重に進めてください。

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

  • リソース待機中、待機時間、または 実行中 の状態 (たとえば、ノードコードが実行中またはデータ品質チェックが進行中の場合) のインスタンスはフリーズできません。

• [復元 (解凍)]：フリーズ状態のインスタンスのフリーズを解除します。

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

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

  説明

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

インスタンス詳細

インスタンス DAG で、特定のインスタンスを左クリックし、ポップアップウィンドウで ログを表示 をクリックするか、詳細の表示 をクリックして プロパティ、運用ログ、操作ログ、コード などの詳細情報を表示します。