airflow

Airflow の運用

Airflow とのやり取りには、Airflow VS Code 拡張機能のツールを使用してください。Airflow の運用にシェルコマンドを使用しないでください。

ツールのクイックリファレンス

ツール	目的
list_active_dags	アクティブ（一時停止されていない）DAG を一覧表示します
list_paused_dags	一時停止中の DAG を一覧表示します
get_running_dags	実行中またはキューに登録されている DAG 実行を表示します
pause_dag	DAG を一時停止します
unpause_dag	DAG の一時停止を解除します
trigger_dag_run	DAG の実行をトリガーします
get_dag_runs	DAG の実行を一覧表示します
get_dag_history	DAG の日次実行履歴を表示します
get_failed_runs	すべての DAG の失敗した実行を表示します
analyse_dag_latest_run	最新の実行を包括的に分析します（タスク、ログ、ソース）
get_dag_run_detail	特定の実行を包括的に分析します
get_dag_source_code	DAG のソースコードを取得します
go_to_dag_view	DAG ビューパネルを開きます
go_to_dag_log_view	ログビューパネルを開きます
go_to_connections_view	接続パネルを開きます
go_to_variables_view	変数パネルを開きます
go_to_providers_view	プロバイダーパネルを開きます
go_to_configs_view	設定パネルを開きます
go_to_plugins_view	プラグインパネルを開きます
go_to_server_health_view	サーバーのヘルスパネルを開きます

ユーザーの意図のパターン

DAG の操作

• 「すべての DAG を一覧表示」→ list_active_dags と list_paused_dags
• 「DAG のソースを表示」→ get_dag_source_code
• 「DAG X を一時停止」→ pause_dag
• 「DAG X を再開」→ unpause_dag

実行の操作

• 「DAG X をトリガー」→ trigger_dag_run
• 「最近の実行を表示」→ get_dag_runs
• 「なぜ失敗したのか」→ analyse_dag_latest_run または get_dag_run_detail

ログとトラブルシューティング

• 「タスクのログを表示」→ go_to_dag_log_view または analyse_dag_latest_run
• 「最新の実行を分析」→ analyse_dag_latest_run

システムと設定

• 「接続を表示」→ go_to_connections_view
• 「変数を表示」→ go_to_variables_view
• 「サーバーのヘルスを確認」→ go_to_server_health_view

よくあるワークフロー

失敗した実行を調査する

1. 失敗を確認します：get_failed_runs
2. 最新の実行を分析します：analyse_dag_latest_run
3. 特定の実行 ID がわかっている場合：get_dag_run_detail
4. 必要に応じてログを開きます：go_to_dag_log_view

トリガーして監視する

1. トリガーします：trigger_dag_run
2. ステータスを確認します：get_dag_runs
3. 失敗した場合は分析します：analyse_dag_latest_run

朝のヘルスチェック

1. サーバーのヘルスを確認します：go_to_server_health_view
2. 実行中の DAG を確認します：get_running_dags
3. 最近の失敗を確認します：get_failed_runs