example - Suba archivos usando SFTP en Python, pero cree directorios si la ruta no existe

sftp python

Question

Quiero cargar un archivo en un servidor remoto con Python. Me gustaría comprobar de antemano si la ruta remota realmente existe, y si no es así, crearla. En pseudocódigo:

if(remote_path not exist):
create_path(remote_path)
upload_file(local_file, remote_path)

Estaba pensando en ejecutar un comando en Paramiko para crear la ruta (por ejemplo, mkdir -p remote_path ). Se me ocurrió esto:

# I didn''t test this code
import paramiko, sys
ssh = paramiko.SSHClient()
ssh.connect(myhost, 22, myusername, mypassword)
ssh.exec_command(''mkdir -p '' + remote_path)
ssh.close
transport = paramiko.Transport((myhost, 22))
transport.connect(username = myusername, password = mypassword)
sftp = paramiko.SFTPClient.from_transport(transport)
sftp.put(local_path, remote_path)
sftp.close()
transport.close()

Pero esta solución no me suena bien, porque cierro la conexión y la vuelvo a abrir. Hay una mejor manera de hacerlo?

Answer 1

Algo más simple y un poco más legible también

def mkdir_p(sftp, remote, is_dir=False):
"""
emulates mkdir_p if required.
sftp - is a valid sftp object
remote - remote path to create.
"""
dirs_ = []
if is_dir:
dir_ = remote
else:
dir_, basename = os.path.split(remote)
while len(dir_) > 1:
dirs_.append(dir_)
dir_, _ = os.path.split(dir_)
if len(dir_) == 1 and not dir_.startswith("/"):
dirs_.append(dir_) # For a remote path like y/x.txt
while len(dirs_):
dir_ = dirs_.pop()
try:
sftp.stat(dir_)
except:
print "making ... dir", dir_
sftp.mkdir(dir_)

Answer 2

Paramiko contiene una función mkdir:

http://paramiko-docs.readthedocs.org/en/latest/api/sftp.html#paramiko.sftp_si.SFTPServerInterface.mkdir

Answer 3

SFTP es compatible con los comandos FTP habituales (chdir, mkdir, etc ...), así que usa esos:

sftp = paramiko.SFTPClient.from_transport(transport)
try:
sftp.chdir(remote_path) # Test if remote_path exists
except IOError:
sftp.mkdir(remote_path) # Create remote_path
sftp.chdir(remote_path)
sftp.put(local_path, ''.'') # At this point, you are in remote_path in either case
sftp.close()

Para emular completamente mkdir -p , puedes trabajar a través de remote_path recursivamente:

import os.path
def mkdir_p(sftp, remote_directory):
"""Change to this directory, recursively making new folders if needed.
Returns True if any folders were created."""
if remote_directory == ''/'':
# absolute path so change directory to root
sftp.chdir(''/'')
return
if remote_directory == '''':
# top-level relative directory must exist
return
try:
sftp.chdir(remote_directory) # sub-directory exists
except IOError:
dirname, basename = os.path.split(remote_directory.rstrip(''/''))
mkdir_p(sftp, dirname) # make parent directories
sftp.mkdir(basename) # sub-directory missing, so created it
sftp.chdir(basename)
return True
sftp = paramiko.SFTPClient.from_transport(transport)
mkdir_p(sftp, remote_path)
sftp.put(local_path, ''.'') # At this point, you are in remote_path
sftp.close()

Por supuesto, si remote_path también contiene un nombre de archivo remoto, entonces debe dividirse, el directorio se pasa a mkdir_p y el nombre de archivo usado en lugar de ''.'' en sftp.put.

Answer 4

Suponiendo que las operaciones de sftp son caras, me gustaría ir con:

def sftp_mkdir_p(sftp, remote_directory):
dirs_exist = remote_directory.split(''/'')
dirs_make = []
# find level where dir doesn''t exist
while len(dirs_exist) > 0:
try:
sftp.listdir(''/''.join(dirs_exist))
break
except IOError:
value = dirs_exist.pop()
if value == '''':
continue
dirs_make.append(value)
else:
return False
# ...and create dirs starting from that level
for mdir in dirs_make[::-1]:
dirs_exist.append(mdir)
sftp.mkdir(''/''.join(dirs_exist))```

Answer 5

Tenía que hacer esto hoy. Así es como lo hice.

def mkdir_p(sftp, remote_directory):
dir_path = str()
for dir_folder in remote_directory.split("/"):
if dir_folder == "":
continue
dir_path += r"/{0}".format(dir_folder)
try:
sftp.listdir(dir_path)
except IOError:
sftp.mkdir(dir_path)