¿Cómo eliminar todos los archivos del directorio en el servidor remoto en python?

Question

Me gustaría eliminar todos los archivos de un directorio determinado en un servidor remoto al que ya estoy conectado usando paramiko. Sin embargo, no puedo dar explícitamente los nombres de los archivos, porque variarán según la versión del archivo que haya colocado allí anteriormente.

Aquí es lo que estoy tratando de hacer ... la línea por debajo de la #TODO es la llamada que estoy tratando donde remoteArtifactPath es algo así como "/ opt/foo/*"

ssh = paramiko.SSHClient() 
ssh.load_host_keys(os.path.expanduser(os.path.join("~", ".ssh", "known_hosts"))) 
ssh.connect(server, username=username, pkey=mykey) 
sftp = ssh.open_sftp() 

# TODO: Need to somehow delete all files in remoteArtifactPath remotely 
sftp.remove(remoteArtifactPath+"*") 

# Close to end 
sftp.close() 
ssh.close() 

Cualquier idea ¿Cómo puedo lograr esto?

Gracias

Answer 1

he encontrado una solución: iterar sobre todos los archivos en la ubicación remota, a continuación, llamar remove en cada una de ellas:

ssh = paramiko.SSHClient() 
ssh.load_host_keys(os.path.expanduser(os.path.join("~", ".ssh", "known_hosts"))) 
ssh.connect(server, username=username, pkey=mykey) 
sftp = ssh.open_sftp() 

# Updated code below: 
filesInRemoteArtifacts = sftp.listdir(path=remoteArtifactPath) 
for file in filesInRemoteArtifacts: 
    sftp.remove(remoteArtifactPath+file) 

# Close to end 
sftp.close() 
ssh.close() 

Answer 2

Una rutina Fabric podría ser tan simple como esto:

with cd(remoteArtifactPath): 
    run("rm *") 

Tela es grande para la ejecución de comandos shell en servidores remotos. La tela realmente usa Paramiko debajo, por lo que puede usar ambas si lo necesita.

Answer 3

Necesita una rutina recursiva ya que su directorio remoto puede tener subdirectorios.

def rmtree(sftp, remotepath, level=0): 
    for f in sftp.listdir_attr(remotepath): 
     rpath = posixpath.join(remotepath, f.filename) 
     if stat.S_ISDIR(f.st_mode): 
      rmtree(sftp, rpath, level=(level + 1)) 
     else: 
      rpath = posixpath.join(remotepath, f.filename) 
      print('removing %s%s' % (' ' * level, rpath)) 
      sftp.remove(rpath) 
    print('removing %s%s' % (' ' * level, remotepath)) 
    sftp.rmdir(remotepath) 

ssh = paramiko.SSHClient() 
ssh.load_host_keys(os.path.expanduser(os.path.join("~", ".ssh", "known_hosts"))) 
ssh.connect(server, username=username, pkey=mykey) 
sftp = ssh.open_sftp() 
rmtree(sftp, remoteArtifactPath) 

# Close to end 
stfp.close() 
ssh.close()