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

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

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)

谢谢!



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5662854.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存