AirflowSFTPHooktransport.py中使用私钥进行身份验证时，认证（密码）失败
出现此问题的原因通常是由于使用SFTPHook连接远程服务器时，没有正确配置私钥的信息。
解决此问题的步骤是：
-
确保私钥文件的路径正确，并且权限正确。可以使用以下命令更改权限：
chmod 400 your_ssh_key
-
确保在连接远程服务器时正确使用私钥的信息。可以使用以下代码配置私钥：
import os from datetime import timedelta from airflow import DAG from airflow.contrib.hooks.ssh_hook import SSHHook from airflow.contrib.operators.sftp_operator import SFTPOperator
ssh_hook = SSHHook(ssh_conn_id='
', key_file=' ') ssh_conn_id：连接ssh的id key_file：私钥文件名（包含路径） dag = DAG('sftp_operator_example', default_args={ 'owner': 'airflow', 'depends_on_past': False, 'start_date': datetime(2022, 11, 1), 'email': ['test@test.com'], 'email_on_failure': False, 'email_on_retry': False, }, dagrun_timeout=timedelta(minutes=60), description='SFTP Operator Example', schedule_interval='@once' )
sftp_example = SFTPOperator(task_id='sftp_example', ssh_hook=ssh_hook, local_filepath='/path/to/localfile', remote_filepath='/path/to/remote_file', operation='put', dag=dag)
sftp_example
在上面的代码中，我们创建了一个SFTPOperator任务，使用SSH连接和对应的私钥文件执行SFTP操作。
-
确认输入的密码是否是正确的，如果不是，则更改密码即可。
-
最重要的是，要确保您连接的远程服务器能够接受您使用的私钥进行身份验证。
按照上述步骤确保正确配置私钥信息以及正确设置连接远程服务器，您的操作应该可以成功执行。