スケジュールとトリガーを使用してジョブを自動化する

次のいずれかの状況で自動的にトリガーされるように Lakeflow ジョブを構成します。

  • 時間ベースのスケジュールで
  • ソース テーブルの更新時
  • Unity カタログの保存場所へのファイルの到着時
  • Unity カタログ モデルの作成または更新時
  • 継続的に

手動または外部オーケストレーション ツールを使用して、ジョブの実行をトリガーすることもできます。

ジョブのスケジュールとトリガー

トリガーの種類 行動
スケジュール済み 時間ベースのスケジュールに基づいてジョブの実行をトリガーします。 「スケジュールに基づいてジョブを実行する」を参照してください。
テーブルの更新 ソース テーブルが更新されたときにジョブの実行をトリガーします。 ソース テーブルが更新されたときにジョブをトリガーするを参照してください。
ファイルの到着 監視対象の Unity カタログの保存場所に新しいファイルが到着したときにジョブの実行をトリガーします。 「新しいファイルが到着したときにジョブをトリガーする」を参照してください。
モデルの更新 Unity カタログ モデルの作成、モデル バージョンの準備完了、またはモデル エイリアスの設定 (ベータ) 時にジョブ実行をトリガーします。 モデルが更新されたときにジョブをトリガーするを参照してください。
継続的 ジョブを常に実行し続けるには、ジョブの実行が完了または失敗するたびに、別のジョブ実行をトリガーします。 「ジョブを継続的に実行する」を参照してください。
なし (手動) 実行は、[今すぐ実行] ボタンを使用して手動でトリガーされるかその他のオーケストレーション ツールを使用してプログラムによってトリガーされます。 「1 回のジョブ実行トリガー」を参照してください

既定では、一度にアクティブにできるジョブの実行は 1 つだけです。 ただし、[詳細設定] でこの制限を引き上げることは可能です。 実行は、ジョブに対して構成された最大コンカレンシーを超えるとスキップされます。 「同時実行の最大数を構成する」を参照してください。

ジョブのトリガーの構成

  1. トリガーを構成するジョブを開きます。

  2. [ ジョブの詳細 ] ウィンドウで、[ スケジュールとトリガー ] セクションまで下にスクロールし、[ トリガーの追加] をクリックします。

  3. [スケジュールとトリガー] で、構成するトリガーの種類 (スケジュールテーブルの更新ファイルの到着モデルの更新または継続的) を選択します。

    トリガーの種類に基づいて、他のオプションも構成できます。

  4. [保存] をクリックします。 保存すると、構成されたトリガーに基づいてジョブが自動的に実行されます。

注記

複数のタスクを含むジョブ内の 1 つ以上のタスクが成功しない場合、失敗したタスクのサブセットを再実行できます。 「失敗したタスクとスキップされたタスクを再実行する」を参照してください。

既存のトリガーを管理する

トリガーを編集、一時停止、再開、または削除するには、[ジョブの詳細] ウィンドウの [スケジュールとトリガー] セクションを使用します。 これらのコントロールは、トリガーが構成されているジョブにのみ表示されます。

  • トリガーを変更するには、[ トリガーの編集] をクリックします。
  • アクティブなトリガーを一時停止するには、[ 一時停止] をクリックします。 現在アクティブな実行はすべて続行されますが、トリガーは新しい実行を開始しなくなりました。 トリガーを再開するには、[ 再開] をクリックします。構成された動作は、以前に構成したのと同じスケジュールで再開されます。
  • ジョブからトリガーを削除するには、[削除] をクリック します

トリガーを作成または編集するときに、[スケジュールとトリガー] ダイアログで [アクティブ] と [一時停止] を切り替えてトリガーの状態を制御することもできます。

注記

継続的トリガーが再開されたときに実行がアクティブな場合、ジョブ スケジューラは、その実行が完了するまで待機して新しい実行をトリガーします。