自動トリガー タスクは、スケジューリングシステムにコミットされた後、スケジュールに従って自動的に実行されます。 [オペレーションセンター] の [自動トリガー ノード] ページで、ワークスペース内の自動トリガー タスクのリストを表示したり、本番環境にデプロイされている自動トリガー タスクの構成を表示したり、自動トリガー タスクを管理したりできます。
背景情報
DataWorks では、自動トリガー タスクはスケジューリング設定に基づいてシステムによって自動的にスケジュールされます。自動トリガー タスクは、オペレーションセンターの [自動トリガー ノード] ページで表示できます。自動トリガー タスクは、手動でトリガーすることもできます。自動トリガー タスクを手動でトリガーする場合、タスクのデータをバックフィルしたり、テストしたりできます。その後、システムはタスクのデータバックフィル インスタンスまたはテスト インスタンスを生成します。データバックフィル インスタンスまたはテスト インスタンスを使用して、データ処理またはデバッグを実行できます。自動トリガー タスクが指定された条件を満たしている場合、システムは毎晩 23:30 にタスクの自動トリガー インスタンスを自動的に生成し、次の日にインスタンスを実行します。
本番環境にデプロイされている自動トリガー タスクを変更した場合、変更は変更完了後にタスクに対して生成されるインスタンスに反映されます。ほとんどの場合、自動トリガー タスクの変更は、翌日のタスクのスケジュール時刻になると有効になります。たとえば、スケジュール時刻が翌日のある時点に設定されている自動トリガー タスクをデプロイする場合、システムは現在の日の 23:30 にタスクの自動トリガー インスタンスを生成し、翌日のスケジュール時刻にインスタンスを実行します。自動トリガー タスクのデータをバックフィルする場合、システムはタスクの構成に基づいてタスクのデータ バックフィル インスタンスをすぐに生成し、データ バックフィル インスタンスは手動でトリガーした直後に有効になります。作成、デプロイ、実行、一時停止、デプロイ解除などの操作については、「自動トリガー タスクの基本的な O&M 操作の実行」をご参照ください。
制限
DataWorks Professional Edition 以上をご利用のお客様のみ、有向非循環グラフ (DAG) が提供する集約、上流分析、下流分析機能をご利用いただけます。 DataWorks サービスのエディションアップグレードの請求ルールについては、「DataWorks エディションの請求」をご参照ください。
注意事項
ワークスペース名_root形式で名前が付けられたタスクは凍結しないでください。このタスクはワークスペースのルート タスクです。自動トリガー タスクのすべてのインスタンスはこのタスクに依存しています。このタスクが凍結されていると、自動トリガー タスクのインスタンスを実行できません。自動トリガー タスクを変更した後、タスクをデプロイする必要があります。タスクが正常にデプロイされると、変更は本番環境に反映されます。自動トリガー タスクをデプロイすると、タスクのデプロイに失敗する、デプロイ プロセスがブロックされる、デプロイされたタスクのバージョンが期待どおりでないなどの例外が発生する場合があります。このような場合は、[オペレーションセンター] の [自動トリガー ノード] ページに移動して問題のトラブルシューティングを行うことをお勧めします。
[自動トリガー ノード] ページに移動する
DataWorks コンソール にログインします。上部のナビゲーションバーで、目的のリージョンを選択します。左側のナビゲーションウィンドウで、 を選択します。表示されたページで、ドロップダウンリストから目的のワークスペースを選択し、[オペレーションセンターに移動] をクリックします。
[オペレーションセンター] ページの左側のナビゲーションウィンドウで、 を選択します。 [自動トリガー ノード] ページで、自動トリガー タスクのリストまたは自動トリガー タスクの DAG を表示します。
自動トリガー タスクを表示する
[自動トリガー ノード] ページには、スケジューリングシステムにコミットされているすべてのタスクが表示されます。 インテリジェント検索 をクリックし、フィルター条件を指定して、目的の自動トリガー タスクを検索できます。フィルター条件を直接指定して、目的の自動トリガー タスクを検索することもできます。
インテリジェント検索機能を使用して自動トリガー タスクを検索する 機能を使用して自動トリガー タスクを検索する
[自動トリガー ノード] ページには、[インテリジェント検索] 機能が用意されています。 [インテリジェント検索] をクリックしてフィルター条件を選択または入力すると、フィルター条件に一致する自動トリガー タスクが自動的に表示されます。
[インテリジェント検索] 機能を使用して検索を実行します。
[自動トリガー タスク] ページの上部にある [インテリジェント検索] をクリックします。表示される検索ボックスにフィルター条件を入力または選択し、Enter キーを押します。フィルター条件に一致する自動トリガー タスクが自動的に表示されます。たとえば、
タスク タイプでソートというフィルター条件を入力できます。ビューを保存します。
後続の操作でフィルター条件を引き続き使用する場合、次の手順を実行して、フィルタリング後に表示される自動トリガー タスクのリストを新しいビューとして保存します。 [未保存のビュー] をクリックし、ドロップダウンリストから [新しいビューとして保存] を選択します。 [ビューの保存] ダイアログボックスで、[ビュー名] パラメーターを構成し、[保存] をクリックします。その後、ビュー検索ドロップダウンリストでビューを見つけて、ビューを使用して目的の自動トリガー タスクを検索できます。
説明ビューが不要になった場合は、ビュー検索ドロップダウンリストで見つけて、ビュー名の横にある [詳細] アイコンにポインターを移動し、[編集] または [削除] を選択してビューを変更または削除できます。
[インテリジェント検索] 機能を無効にします。
フィルター条件に基づいて完全一致を実行する場合、Esc キーを押すか、[インテリジェント検索を無効にする] をクリックしてインテリジェント検索モードを終了します。
フィルター条件を直接指定して自動トリガー タスクを検索するフィルター条件を直接指定して自動トリガー タスクを検索する
自動トリガーノードページに表示されるフィルター条件を使用して、目的の自動トリガータスクを検索できます。
単純なフィルター条件に基づいて検索を実行します。
タスク名またはタスク ID を指定するか、[ノードタイプ]、[過去 180 日以内に期限切れ]、[参照済み] などのフィルター条件を選択して、目的の自動起動タスクを検索します。
複雑なフィルター条件に基づいて検索を実行します。
[フィルター] アイコンをクリックします。表示されるダイアログボックスで、タスク名またはタスク ID を指定するか、[コンピューティングリソースの種類]、[ベースライン]、[優先度] などのフィルター条件を設定して、目的の自動起動タスクを検索します。
凍結されたタスク: 凍結された自動トリガー タスクは自動的にスケジュールされず、その子孫タスクの実行はブロックされます。自動トリガー タスクが凍結されている場合、タスクに対して生成されたインスタンスも凍結されます。凍結されたインスタンスは自動的にスケジュールされず、自動トリガー タスクの子孫タスクの実行はブロックされます。
分離されたタスク: 分離されたタスクは別のタスクに依存しません。このタイプのタスクは自動的にスケジュールされません。分離されたタスクに多数の子孫タスクがある場合、子孫タスクの実行に影響します。詳細については、「シナリオ: 分離されたノード」をご参照ください。
期限切れのタスク: 期限切れのタスクはインスタンスを生成せず、実行されません。
自動トリガーされるタスクを管理する
1 つのタスクを管理する
自動的にトリガーされる単一のタスクを管理する場合、[自動トリガーノード] ページでタスクを見つけ、[アクション] 列にあるさまざまな機能のエントリポイントをクリックします。
機能 | 説明 | |
DAG | 自動トリガー タスクの DAG には、タスクの依存関係が表示されます。タスクの DAG で自動トリガー タスクに対して操作を実行できます。詳細については、「自動トリガー タスクの DAG を表示する」をご参照ください。 | |
テスト | この機能を使用すると、自動トリガー タスクの実行が期待どおりであるかどうかをテストできます。タスクの [アクション] 列で [テスト] をクリックすると、タスクのテスト インスタンスが生成されます。[テスト インスタンス] ページに移動して、テスト インスタンスのステータスを表示できます。詳細については、「自動トリガー タスクをテストし、タスクに対して生成されたテスト インスタンスを表示する」をご参照ください。 説明 テスト インスタンスはデータを生成します。必要な場合にのみ、この操作を実行してください。 | |
データ バックフィル | この機能を使用すると、過去または将来の一定期間、自動トリガー タスクのデータをバックフィルできます。自動トリガー タスクのデータをバックフィルすると、タスクのデータ バックフィル インスタンスが生成されます。[データ バックフィル] ページに移動して、データ バックフィル インスタンスのステータスを表示できます。詳細については、「データをバックフィルし、データ バックフィル インスタンスを表示する (新バージョン)」をご参照ください。 | |
その他 | 凍結 | 自動トリガー タスクとその子孫タスクを一定期間実行したくない場合は、[凍結] をクリックしてタスクを凍結できます。 凍結された自動トリガー タスクに対して生成されたインスタンスも凍結状態になります。凍結されたインスタンスは実行されず、子孫タスクの実行をブロックします。 説明
|
凍結解除 | この機能を使用すると、凍結された自動トリガー タスクを再開できます。 | |
所有者の変更 | この機能を使用すると、自動トリガー タスクの所有者を変更できます。 | |
スケジューリング リソース グループの変更 | この機能を使用すると、自動トリガー タスクの実行に使用するスケジューリング用のリソース グループを変更できます。 | |
ラベルの変更 | この機能を使用すると、自動トリガー タスクにタグを追加、削除、または変更できます。自動トリガー タスクのタグを管理する方法の詳細については、「タグを管理する」をご参照ください。 | |
データ品質ルールの構成 | この機能を使用すると、自動トリガー タスクのデータ品質監視ルールを構成して、タスクの実行時にタスクのデータ品質を確認できます。詳細については、「概要」をご参照ください。 | |
インスタンスの表示 | この機能を使用すると、[自動トリガー インスタンス] ページで、自動トリガー タスクに対して生成された自動トリガー インスタンスを表示できます。 | |
系列の表示 | この機能を使用すると、自動トリガー タスクのデータ系列を表示できます。 | |
周期タスクの詳細の表示 | この機能を使用すると、自動トリガー タスクの基本プロパティを表示できます。関連パラメーターの詳細については、「自動トリガー タスクの詳細を表示する」をご参照ください。 | |
アラート ルールの追加 | この機能を使用すると、カスタム アラート ルールを構成して、自動トリガー タスクのステータスを毎日監視できます。構成が完了したら、[オペレーションセンター] ページの左側のナビゲーション ウィンドウで を選択して、構成済みのカスタム アラート ルールを表示できます。詳細については、「カスタム アラート ルールを作成する」をご参照ください。 | |
ベースラインの追加 | この機能を使用すると、自動トリガー タスクをベースラインに関連付けることができます。ベースラインの詳細については、「概要」をご参照ください。 | |
複数の自動トリガー タスクを同時に管理する
複数の自動トリガー タスクを同時に管理する場合、[自動トリガーノード] ページでタスクを選択し、ページ下部にある [凍結] や [凍結解除] などの操作のエントリポイントを クリック します。
自動トリガーされるタスクの DAG を表示する
自動トリガー タスクの DAG を表示する場合、[自動トリガー ノード] ページでタスクを見つけ、[アクション] 列の [DAG] をクリックします。
自動トリガー タスクの DAG の機能
次の表に、自動トリガー タスクの DAG で提供される機能を示します。
機能 (アイコンで表示) | 説明 | |
| 自動トリガー タスクの DAG の左上隅にあるアイコンをクリックすると、次のいずれかのディメンションからタスク情報を集約したり、集約をキャンセルしたりできます。
| |
| 自動トリガー タスクに複数の子孫タスクがある場合、または自動トリガー タスクの子孫タスクが複数のレベルに分散している場合、[ダウングレード分析] 機能を使用して、現在のタスクの影響を受ける子孫タスクの数を計算できます。 | |
| 自動トリガー タスクの DAG の右上隅にあるアイコンをクリックすると、DAG の表示スタイルを調整できます。 | |
自動トリガー タスクの DAG で実行できる操作
自動トリガー タスクの DAG では、タスク名を右クリックしてさまざまな操作を実行できます。例:
祖先ノードを表示: さまざまなレベルで自動トリガー タスクの祖先タスクを表示します。最大 6 レベルの祖先タスクを同時に表示できます。この操作を実行して、現在の自動トリガー タスクのデータ出力に影響を与える祖先タスクを表示できます。
子孫ノードを表示: さまざまなレベルで自動トリガー タスクの子孫タスクを表示します。最大 6 レベルの子孫タスクを同時に表示できます。この操作を実行して、データ出力が現在の自動トリガー タスクの影響を受ける可能性のある子孫タスクを表示できます。
コードを表示: 本番環境で自動トリガー タスクのコードを表示します。自動トリガー タスクのコードが期待どおりでない場合は、タスクの最新のコードが本番環境に正常にデプロイされているかどうかを確認する必要があります。タスクを本番環境にデプロイする方法については、「タスクのデプロイ」をご参照ください。
[ノードの編集]: DataStudio ページのタスクの構成タブで、自動的にトリガーされるタスクを編集します。
その他の操作については、「自動トリガー タスクに対する操作の実行」をご参照ください。
自動トリガー タスクの詳細を表示する
自動トリガー タスクの DAG では、タスクの基本プロパティ、詳細プロパティ、操作ログ、およびコードを表示できます。これは、タスクのスケジューリング パラメーター、リソースグループ、およびコードがビジネス要件を満たしているかどうかを確認するのに役立ちます。
自動トリガー タスクの DAG で、タスク名をクリックします。 DAG の右下隅に表示されるカードで、[詳細の表示] をクリックします。表示されるタブで自動トリガー タスクの詳細を表示します。
タブ | 説明 |
全般 | このタブでは、本番環境における自動トリガー タスクのスケジューリング プロパティを表示できます。基本パラメーターの詳細については、「基本プロパティの構成」をご参照ください。 説明 [DataStudio] ページの自動トリガー タスクのパラメーター構成が、[オペレーションセンター] の [自動トリガー ノード] ページのタスクのパラメーター構成と一致しない場合は、タスクを変更した後にタスクを正常にデプロイしたかどうかを確認することをお勧めします。
|
操作ログ | このタブでは、操作時刻、オペレーター、特定の操作など、自動トリガー タスクの操作レコードを表示できます。 |
コード | このタブでは、本番環境における自動トリガー タスクの最新のコードを表示できます。タスクのコードが期待どおりでない場合は、タスクの最新のコードが本番環境に正常にデプロイされているかどうかを確認する必要があります。詳細については、「タスクのデプロイ」をご参照ください。 |