我想我只是想通了：
在用户界面中的管理>连接下创建SSH连接。注意：如果您重置数据库，连接将被删除
在Python文件中添加以下内容
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)
谢谢！
我想我只是想通了：
在用户界面中的管理>连接下创建SSH连接。注意：如果您重置数据库，连接将被删除
在Python文件中添加以下内容
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)
谢谢！
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
