スケジュールとトリガーを使用したジョブの自動化
Lakeflow ジョブを次のいずれかの状況で自動的にトリガーされるように設定する：
- 時間ベースのスケジュールで
- ソーステーブルが更新されたとき
- Unity Catalog の保存場所にファイルが到着したとき
- Unity Catalogモデルの作成または更新時
- 継続
また、ジョブの実行を手動でトリガーすることも、外部のオーケストレーション ツールを使用してトリガーすることもできます。
ジョブ・スケジュールとトリガー
トリガータイプ | 挙動 |
|---|---|
スケジュール | 時間ベースのスケジュールに基づいてジョブの実行をトリガーします。 スケジュールに従ってジョブを実行するを参照してください。 |
テーブルの更新 | ソーステーブルが更新されたときにジョブの実行をトリガーします。ソーステーブルが更新されたときにジョブをトリガーするを参照してください。 |
ファイル到着 | 監視対象の Unity Catalog ストレージの場所に新しいファイルが到着したときに、ジョブの実行をトリガーします。 新しいファイルの到着時にジョブをトリガーするを参照してください。 |
モデルの更新 | Unity Catalogモデルが作成されたとき、モデルバージョンの準備が整ったとき、またはモデルエイリアスが設定されたとき (ベータ版) にジョブが実行されます。モデルが更新されたときにジョブをトリガーするを参照してください。 |
連続 | ジョブを常に実行し続けるには、ジョブの実行が完了または失敗するたびに別のジョブ実行をトリガーします。 ジョブの継続的な実行を参照してください。 |
なし（手動） | 実行は、 今すぐ実行 ボタンを使用して手動でトリガーするか、他のオーケストレーション ツールを使用してプログラムでトリガーされます。 1 つのジョブ実行をトリガーするを参照してください |
デフォルトでは、一度にアクティブにできるジョブの実行は 1 つだけです。 ただし、詳細設定でこの制限を増やすことは可能です。 実行は、ジョブに設定された最大同時実行数を超えるとスキップされます。 最大並列実行の構成を参照してください。
ジョブのトリガーを構成する
-
トリガーを構成するジョブを開きます。
-
ジョブの詳細 ウィンドウで、 スケジュールとトリガー セクションまで下にスクロールし、 トリガーの追加 をクリックします。
-
スケジュールとトリガー で、設定するトリガーのタイプ ( スケジュール済み 、 テーブル更新 、 ファイルの到着 、 モデル更新 、または 継続 ) を選択します。
トリガーのタイプに基づいて、他のオプションも構成できます。
-
「 保存 」をクリックします。保存後、ジョブは構成されたトリガーに基づいて自動的に実行されます。
複数のタスクを持つジョブの 1 つ以上のタスクが失敗した場合は、失敗したタスクのサブセットを再実行できます。 失敗したタスクとスキップされたタスクの再実行を参照してください。
既存のトリガーを管理する
トリガーを編集、停止する、再開、または削除するには、 ジョブの詳細 ペインの スケジュールとトリガー セクションを使用します。これらのコントロールは、トリガーが設定されているジョブにのみ表示されます。
- トリガーを変更するには、 [トリガーを編集] をクリックします。
- アクティブなトリガーを停止するには、 停止する をクリックします。現在アクティブな実行は続行されますが、トリガーは新しい実行を開始しなくなります。トリガーを再開するには、 再開 をクリックします。以前に設定されたのと同じスケジュールで、設定された動作が再開されます。
- ジョブからトリガーを削除するには、 削除 をクリックします。
トリガーを作成または編集する際、[スケジュールとトリガー]ダイアログで**アクティブ**と**一時停止**を切り替えて**トリガーステータス**を制御することもできます。
連続トリガーが再開されたときに実行がアクティブである場合、ジョブ・スケジューラーは、その実行が完了するまで待機して新しい実行をトリガーします。