Advertisement
Guest User

Untitled

a guest
Jun 18th, 2019
75
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.52 KB | None | 0 0
  1. df = pd.read_csv(...)
  2.  
  3. def read_file_sftp_local_memory(sftp, path, filename):
  4.  
  5. flo = BytesIO()
  6. path_query = "".join(['RETR ', path, '/', filename])
  7. sftp.retrbinary(path_query, flo.write)
  8. flo.seek(0)
  9. return flo
  10.  
  11. def read_file_csv(sftp, path, filename):
  12.  
  13. # Download
  14. sftp.get("/".join( os.path.join(path, filename) ), filename)
  15.  
  16. # Read
  17. df = pd.read_csv(filename)
  18.  
  19. # Delete
  20. os.remove(filename)
  21.  
  22. # Return
  23. return df
  24.  
  25. raise IOError(text)
  26. OSError: Failure
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement