您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

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

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

我想我只是想通了:

用户界面中的管理>连接下创建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)

谢谢!

其他 2022/1/1 18:25:51 有555人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶