1. ホーム
  2. airflow

[解決済み] Airflow:DAGを削除する方法は?

2022-02-07 19:33:33

質問内容

AirflowのWebサーバーを起動し、いくつかのダグをスケジュールしました。私はウェブGUI上でダグを見ることができます。

特定のDAGを実行してWeb GUIに表示しないようにするには、どうすればよいですか?それを行うためのAirflow CLIコマンドはありますか?

いろいろ探しましたが、一度ロードしてスケジュールしたDAGを削除する簡単な方法についての回答は見つかりませんでした。

解決方法を教えてください。

Edit 8/27/18 - Airflow 1.10がPyPIでリリースされました!

https://pypi.org/project/apache-airflow/1.10.0/


DAGを完全に削除する方法

Airflow ≥ 1.10 でこの機能が搭載されました!

PR #2199 (Jiraの AIRFLOW-1002 ) Airflow に DAG 削除を追加することは、現在、すべての関連するテーブルから DAG のエントリを完全に削除することができるようにマージされました。

コアとなる delete_dag(...) のコードは現在実験的な API の一部であり、利用可能なエントリポイントもあります。 CLI経由 と、また REST API経由 .

CLIを使用します。

airflow delete_dag my_dag_id

REST API (ローカルでウェブサーバを実行)。

curl -X "DELETE" http://127.0.0.1:8080/api/experimental/dags/my_dag_id


REST APIに関する警告 : Airflow クラスタが 認証を使用する を実行します。

Airflow 1.10(最新版)のインストール/アップグレードについて

アップグレードするには、以下のいずれかを実行してください。

export SLUGIFY_USES_TEXT_UNIDECODE=yes

または

export AIRFLOW_GPL_UNIDECODE=yes

次に

pip install -U apache-airflow

を忘れずにチェックしてください。 UPDATING.md をご覧ください。