Airflow Webインターフェイスでは、DAGの一覧を表示できます。それらのDAGの1つをクリックすると、DAGのさまざまなビューやDAGのコードが表示されます。詳細タブには、DAGファイルの名前が表示されますが、パスは表示されません。エアフローDAGのフルパスを表示するにはどうすればよいですか？
私はまたairflow list-dagsを試しましたが、私が探している情報を提供していません。
Webインターフェイスで見ることのできるDAGがありますが、ファイルシステム内のどこにあるのかわかりません。
エアフローWebインターフェイスまたはエアフローCLIからDAGの場所を見つける方法はありますか。
私はそうは思いませんが、あなたのairflow.cfgからdags_folderを検索して、ダッグが作成されている場所を見つけるだけですみます。
さらに、airflow-webserverのログは、ログオンしていると仮定して、インポートされているファイル/ダグを正確に示します。
特にDAGを開発/変更したりDAGファイルを削除すると、エントリがバックエンドDBに残ってUIに表示されることがよくあります。ほとんどの場合、実際にDAGファイルは実際には存在しません。デフォルトで
（ Airflow: how to delete a DAG?からの回答に基づいて）import sys
from airflow.hooks.postgres_hook import PostgresHook
dag_input = sys.argv[1]
hook=PostgresHook(postgres_conn_id= "airflow_db")
for t in ["xcom", "task_instance", "sla_miss", "log", "job", "dag_run", "dag" ]:
sql="delete from {} where dag_id='{}'".format(t, dag_input)
hook.run(sql, True)
エアフローは、いくつかのサンプルのDAGを提供しています。私のようなものを使用して、データベースからのDAGをクリーニングをお勧めしたい
。 DAGはexample_dagsフォルダの下に保持されます。
のDAGのパス： のlib/python2.7 /のsite-packages /気流/ example_dags
UIのメインのDAGの一覧で、DAGポーズトグルの左にあるボタンがあります。それはに解決：
https://<airflow.blah.com>/admin/dagmodel/edit/?id=<dag_id>
気流があなたのDAGファイルがあると考えてどこFilelocはあなたが表示されます。しかし...
ありますDBに保存されている間違っている可能性がありますdags_folderにないDAG。 –
そのサブディレクトリですか？ウェブサーバーのログにはインポートされているすべてのダグがあります。さらに、一度実行されたが、もはや検出されなかったダッグを持つことができますが、それらはウェブUIで異なって見えるでしょう。 – acushner