気流でSSHを実行してPythonOperatorを実行する方法

Question

気流を使ってサーバにsshしてPythonOperatorを実行する方法はありますか？私はSSHExecuteOperatorのようなものを探していますが、bashコマンドを実行する代わりにpython呼び出し可能関数を実行します。

Answer 1

あなたはどのように私は簡単なシェルコマンド を実行するためにSSHExecuteOperatorを使用する場合、正しくウェブUIでSSHHookを設定へ教えてください可能性があり、私はこれを得た： airflow.exceptions.AirflowExceptionを：リモート温度の作成に失敗しました

Answer 2

そのSSHのプライバシーの問題

1. 後藤あなたのホストのSSHサーバを提出し、ssh-keygen -t rsaを実行し、Enterキーを押してあなたがENVを気流するために、そのファイルfiles.copy 2 RSAを取得するすべての方法
2. を入力し、そのフルパスをコピーします

3. ただ、DAGを再コンパイルし

それを実行

{"key_file": "/usr/local/airflow/.ssh/id_rsa.pub", "no_host_key_check": true} 

気流UIからの接続で以下を追加