我想我只是想通了:
在用户界面中的管理>连接下创建SSH连接。注意:如果您重置数据库,连接将被删除
from airflow.contrib.hooks import SSHHook
sshHook = SSHHook(conn_id=
添加SSH操作员任务
t1 = SSHExecuteOperator(
task_id="task1",
bash_command=<YOUR COMMAND>,
ssh_hook=sshHook,
dag=dag)
谢谢!
Airflow:如何从其他服务器进行SSH和运行BashOperator
我想我只是想通了:
在用户界面中的管理>连接下创建SSH连接。注意:如果您重置数据库,连接将被删除
from airflow.contrib.hooks import SSHHook
sshHook = SSHHook(conn_id=
添加SSH操作员任务
t1 = SSHExecuteOperator(
task_id="task1",
bash_command=<YOUR COMMAND>,
ssh_hook=sshHook,
dag=dag)
谢谢!