エアフローに新しいDAGを追加するにはどうすればよいですか？

私はtutorial_2.pyというファイルにDAGを定義しました（実際には、をtutorial_2に変更した場合を除き、airflowチュートリアルで提供されているtutorial.pyのコピーです）。エアフローに新しいDAGを追加するにはどうすればよいですか？

私は私のデフォルトの内部を見る

、（ ~/airflowにあります）無修正 airflow.cfgは、私が dags_folderが /home/alex/airflow/dagsに設定されていることがわかります。

私はcd /home/alex/airflow; mkdir dags; cd dags; cp [...]/tutorial_2.py tutorial_2.pyです。今度は先ほど作成したtutorial_2.pyファイルを含むairflow.cfgに設定されたパスに一致するdagsフォルダがあります。

しかし、airflow list_dagsを実行すると、デフォルトのチュートリアルDAGに対応する名前しか取得できません。

DAGリストにtutorial_2が表示されているので、やり取りを開始できます。 python tutorial_2.pyもairflow resetdbもリストに表示されていません。

これをどのように修正すればよいですか？

出典

2017-07-01 Aleksey Bilogur

AIRFLOW_HOMEをエクスポートしていないためです。してください： AIRFLOW_HOME="/home/alex/airflow/dags" airflow list_dags 2つのステップよりもうまくいかない場合 export AIRFLOW_HOME="/home/alex/airflow/dags" airflow list_dags これはうまくいくはずです。試してごらん？

出典

2017-07-01 00:40:28

これが正しい答えであるべきと設定されていない場合airflow.cfgは無用ですdags_folder'変数も 'airflow.cfg'に追加しました。私はまだ3つの異なる変数が必要な理由についてはまだ不明です。 cf. [ここ]（https://gitter.im/apache/incubator-airflow?at=59581e6c6ae41d5d33a61aae）。 –

私の理解では、AIRFLOW_HOMEは、airflow.cfgが格納されているディレクトリにリンクする必要があります。次に、airflow.cfgを適用して、dagディレクトリに設定した値に設定することができます。

重要なポイントは次のとおりです。あなたのAIRFLOW_HOMEあなたは* * `airflow_home`と`をチェックし、修正する必要があるかもしれません注意点と、

出典

2017-07-03 06:24:43

ピエールと全く同じです^ –

エアフローに新しいDAGを追加するにはどうすればよいですか？

答えて

関連する問題