Airflow SSHHook Невозможно открыть канал - PullRequest
Новая
       43

Airflow SSHHook Невозможно открыть канал

0 голосов
/ 07 февраля 2020

У меня есть Airflow DAG для доступа к SFTP с помощью оператора SFTP, который полагается на SSHHook, который он некоторое время успешно выполнял, но недавно произошел сбой с этим сообщением об ошибке: paramiko.ssh_exception.SSHException: Unable to open channel.

Кто-нибудь сталкивался? это? или знаете как решить?

Вот мой лог: 

Traceback (most recent call last):
  File "/usr/local/lib/python3.6/site-packages/airflow/models/__init__.py", line 1441, in _run_raw_task
    result = task_copy.execute(context=context)
  File "/efs/workspace/Plugins/sftp_plugin/operators/bark_sftp_to_s3_operator.py", line 44, in execute
    sftp_client = ssh_hook.get_conn().open_sftp()
  File "/usr/local/lib/python3.6/site-packages/paramiko/client.py", line 556, in open_sftp
    return self._transport.open_sftp_client()
  File "/usr/local/lib/python3.6/site-packages/paramiko/transport.py", line 1097, in open_sftp_client
    return SFTPClient.from_transport(self)
  File "/usr/local/lib/python3.6/site-packages/paramiko/sftp_client.py", line 165, in from_transport
    window_size=window_size, max_packet_size=max_packet_size
  File "/usr/local/lib/python3.6/site-packages/paramiko/transport.py", line 879, in open_session
    timeout=timeout,
  File "/usr/local/lib/python3.6/site-packages/paramiko/transport.py", line 1006, in open_channel
    raise e
paramiko.ssh_exception.SSHException: Unable to open channel.
...