authoring-dags

DAG 作成スキル

このスキルでは、ベストプラクティスと VS Code 拡張機能のツールを使用して、Airflow DAG を作成および検証する方法を説明します。

DAG のテストとデバッグについては、testing-dags スキルを参照してください。

重要な警告：拡張機能のツールを使用してください

Airflow のすべての操作には、Airflow VS Code 拡張機能のツールを使用してください。DAG の一覧表示、ログの確認、実行の調査に Airflow CLI コマンドを実行することは避けてください。

ワークフローの概要

1. 調査
2. 計画
3. 実装
4. 検証
5. テスト（ユーザーの同意を得て実施）
6. 改善

フェーズ 1：調査

コードベースを調べる

ファイルツールを使用して、既存のパターンを見つけます。

• リポジトリ内の既存の DAG を検索する
• 類似する DAG を読んで規約を確認する
• 使用中の要件とプロバイダーを確認する

拡張機能のツールを使用して Airflow に問い合わせる

以下のツールを使用して、環境を把握します。

• 命名規則を確認するには、list_active_dags と list_paused_dags を使用する
• 現在のアクティビティを確認するには、get_running_dags を使用する
• 実行頻度を確認するには、get_dag_history を使用する
• 設定を確認するには、go_to_connections_view と go_to_variables_view を使用する
• インストール済みコンポーネントを確認するには、go_to_providers_view と go_to_plugins_view を使用する
• ヘルスチェックには、go_to_server_health_view を使用する

フェーズ 2：計画

以下を提案します。

1. DAG の構成（タスク、依存関係、スケジュール）
2. 使用するオペレーター
3. 必要な接続と変数
4. 必要に応じたパッケージの変更

実装を始める前に、ユーザーの承認を得てください。

フェーズ 3：実装

1. DAG ファイルを作成または更新する
2. 必要に応じて依存関係を更新する
3. ファイルを保存する

フェーズ 4：検証

DAG が Airflow にデプロイされた後、ツールを使用して検証します。

• DAG が list_active_dags または list_paused_dags に表示されることを確認する
• get_dag_source_code を使用して、デプロイされたソースを確認する
• get_dag_history で実行履歴を確認する

フェーズ 5：テスト

testing-dags スキルに従います。

1. 同意を求める
2. trigger_dag_run で実行をトリガーする
3. get_dag_runs と analyse_dag_latest_run で結果を確認する

メモ

• 運用状態の確認に、airflow dags list や astro dev run などの CLI コマンドを使用することは避けてください。
• 実行時の調査とログの確認には、拡張機能のツールを使用してください。