2017-11-30 1 views
0
  1. 私はURLにブラウザを介してアクセスすることができ、リモートマシン上で正常に実行されている気流サービス、持っている:http://airflow.xxx.com
  2. は、今私は動的からのDAGをアップロードしたいの別のマシンをairflow.xxx.comのAirFlowに転送し、そのDAGを自動実行します。
  3. 私は気流の文書を読んだ後

http://airflow.incubator.apache.org/は、私は動的に気流マシンairflow.xxx.com上で行うことができ、それを実行するのDAGを作成し、自動にする方法を見つけました。私は、リモートマシン上に公開された空気の流れにコマンドを送信するにはどうすればよい

しかし、私は別のマシンでそれをしたい、私はそれを達成することができますどのように、私が直接遠隔気流にコマンドを送信してみましょうwebhdfs、などの方法がありますか?

答えて

0

Apache Airflowのdagディレクトリに新しいdagをアップロードする必要があります。

クラスタ環境でセットアップエアフローを設定しなかった場合は、すべて同じマシン上で動作するWebサーバー、スケジューラや労働者を持っている必要があります。あなたがairflow.cfgを改正しなかった場合は、SFTP(またはFTP)を介して他のマシンからエアフローマシンにアクセスする場合は、あなたがdags_folder = /usr/local/airflow/dags

であなたのダグのディレクトリを持っている必要があり、そのマシン上で 、あなたは単にその中にファイルを置くことができますdir。

関連する問題