Airflow：如何从其他服务器进行SSH和运行BashOperator

Airflow：如何从其他服务器进行SSH和运行BashOperator

我想我只是想通了：

1. 在用户界面中的管理>连接下创建SSH连接。注意：如果您重置数据库，连接将被删除

2. 在Python文件中添加以下内容

   from airflow.contrib.hooks import SSHHook

   sshHook = SSHHook(conn_id=)

3. 添加SSH *** 作员任务

   t1 = SSHExecuteOperator(task_id="task1",bash_command=<YOUR COMMAND>,ssh_hook=sshHook,dag=dag)

谢谢！