airflow dag 運行 遠程調度命令 特如 sshpass

有時需要在airflow中運行如sshpass遠程免密登錄調度指令的

所需元素 

1、包：from airflow.contrib.operators.ssh_operator import SSHOperator

2、bash

sh_bash = '''

sshpass -p ‘XXXXXX’ ssh XXXXX@IP  'bash XX.sh'

'''

3、operator

XXXXXX_operator = SSHOperator(

task_id='XXXXXX',

command=sh_bash,

ssh_conn_id='XXXXXXX',

dag=dag)