python - 如何使用 Airflow 通过 RSA 公钥/私钥通过 SSH 连接到服务器？

Question

我有一个 Logstash 服务器，我需要通过使用 Airflow 的 Cloud Composer 运行命令。我正在使用 SH 运算符。我已建立 SSH 连接并将 RSA 私钥添加到 extras 字段。我尝试在输入用户名和未输入用户名时进行连接。每次连接后，我都会收到错误:“错误:SSH 运算符(operator)错误:没有可用的身份验证方法。”我可以使用这个 RSA key 通过 Putty 进行连接。我也可以 PING 服务器。该服务器没有密码 - 只有 key 。SSH操作符代码:

t1 =SSHOperator(
                task_id = 'SSHOperator',

                ssh_hook=sshHook,
                do_xcom_push=True,
                command='ls /logstash/scripts',
                dag=dag
            )

SSH 连接: ssh connection image

Answer 1

为了在Connection内正确传播额外字段参数定义接近SSHOperator连接类型，您应该以 JSON 数据格式显式设置 RSA key 文件的路径，如 Airflow documentation 中共享的那样，例如:

{
   "key_file": "/PATH_TO_YOUR_KEY/.ssh/KEY_NAME_rsa"
}