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、スケジューリングリソースグループ、スケジュール時刻、エンジンインスタンス などの複数の条件を組み合わせ、必要なインスタンスを正確に特定できます。

並べ替えモード

インスタンス一覧を、業務日付、優先度、スケジュール時刻 などのカスタムフィールドで昇順または降順に並べ替えることができます。正常に実行されたワークフローでは、内部タスクを 開始時刻、終了時刻、実行時間 で並べ替えることができます。

単一インスタンスの管理

自動トリガーインスタンスを管理するには、インスタンス一覧で該当インスタンスを特定し、操作 列のオプションを使用します。以下の表に、利用可能な操作を示します。

複数インスタンスの一括管理

一括操作を実行するには、一覧から複数の自動トリガーインスタンスを選択し、下部のボタンを使って 停止、再実行、ステータスを成功に設定、リソースグループの変更、サスペンション (フリーズ)、復元 (解凍) などの操作を実行できます。

検索結果からインスタンス一覧をエクスポートするには、まずフィルターを適用し、インスタンス一覧の上にある クエリ結果のエクスポート ボタンをクリックします。クエリ結果のエクスポート ダイアログボックスで、以下の情報を確認します：

• 対象：現在のフィルター条件に一致するインスタンス数を表示します。「フィルター条件の表示」をクリックすると、具体的なフィルターを確認できます。

• エクスポート方法：「ローカルにエクスポート」を選択します。

DAG パネルの機能

インスタンス DAG 詳細ページでは、DAG パネルの以下の機能を活用して、ノードの集約、下流依存関係の分析、DAG 表示スタイルの調整が可能です。

DAG 操作

インスタンス DAG 詳細ページでは、ワークフロー内のインスタンスを右クリックして、その依存関係、コードの詳細、その他の情報を表示できます。以下の操作が利用可能です：

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

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

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

• インスタンス診断：タスクの上流依存関係、スケジュール時刻、スケジューリングリソース、実行ステータスに対する診断チェックを実行します。

• コードを表示する：本番環境における現在のノードのコードを確認します。期待通りでない場合は、最新バージョンのノードが正常に公開されたか確認してください。

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

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

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

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

• タスク 360 ページへ移動：データガバナンスセンターに移動し、関連するベースラインやインスタンス実行ステータスなど、多角的な観点からタスクの詳細を包括的に把握できます。詳細については、「タスクの包括的ビューの取得」をご参照ください。

• 停止：今後実行しない必要があるタスクを終了します。タスクは失敗ステータスで終了します。停止できるのは、保留中（スケジュール）、保留中（リソース）、または Running 状態のインスタンスのみです。

• 再実行：Successful または Failed 状態のタスクを再実行します。成功すると、未実行の下流タスクのスケジュールがトリガーされます。これは、失敗またはスキップされたノードの処理によく使用されます。

• ダウンストリームで再実行：Successful または Failed 状態のタスクの下流ノードを再実行します。再実行する下流タスクを個別に選択できます。成功すると、未実行の下流タスクのスケジュールがトリガーされます。これは、データバックフィルによく使用されます。

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

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

  説明

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

• Trigger Data Quality Check：タスクに Data Quality ルールが設定されている場合、それらのルールに対するチェックを実行します。

• 緊急操作：これらの操作は、このノードの現在の実行に対してのみ有効です。

  • 削除依存性：指定されたタスクの依存関係を削除し、現在のノードの実行を可能にします。これは、現在のインスタンスとデータ関係がない上流の障害をバイパスする場合によく使用されます。

    説明

    タスクコードおよびデータリネージを確認して、この操作がデータに影響を与えないか検証してください。

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

  • 強制再実行：現在のノードを強制的に再実行します。これは、成功、失敗、または未実行の自動トリガーインスタンスに対して実行できます。データバックフィルによく使用されます。

  • 強制再実行下流：前営業日または前々営業日のデータを再処理するために使用します。これは、成功または失敗した自動トリガーインスタンスに対してのみ実行でき、データバックフィルによく使用されます。詳細については、「付録：子孫ノードの強制再実行」をご参照ください。

    説明

    下流ノードの強制再実行は、ワークスペース管理者、テナント管理者、または主たる Alibaba Cloud アカウントのみが実行できます。

  • Clone Instance：現在の 実行中 インスタンス（ホスト）と同じ構成で新しいインスタンス（クローン）を作成します。新しいインスタンスの名前は dw_clone_NodeName の形式になります。

    説明

    • ODPS SQL ノードのインスタンスのみクローン作成が可能で、各インスタンスは 1 回のみクローン作成できます。

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

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

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

• サスペンション (フリーズ)：現在のインスタンスおよびその下流インスタンスを実行しない必要がある場合にインスタンスをフリーズします。

  重要

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

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

  • 保留中（リソース）、保留中（スケジュール）、または Running 状態（例：ノードコードの実行中、データ品質チェックの実行中）のインスタンスはフリーズできません。

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

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

  • すべての上流タスクがすでに完了している場合、インスタンスは失敗状態に設定され、適切に実行するには手動で再実行する必要があります。

  説明

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

インスタンス詳細の表示

DAG 内で特定のインスタンスを左クリックし、表示されるウィンドウで ログの表示 または 詳細を展開 をクリックすると、属性、実行時ログ、操作ログ、コード などの詳細情報を確認できます。