Advertisement
Guest User

Untitled

a guest
Jul 19th, 2019
77
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.76 KB | None | 0 0
  1. def transfer_chunk_from_ftp_to_s3(
  2. ftp_file,
  3. s3_connection,
  4. muLtipart_upload,
  5. bucket name,
  6. ftp_fiLe_poth,
  7. s3_fiLe_path,
  8. part_number,
  9. chunksize
  10. ):
  11. start_time = time.time()
  12. chunk = ftp_file.read(int(chunk_size))
  13. part = s3_connection.upload_part(
  14. Bucket = bucket_name,
  15. Key = s3_file_path,
  16. PartNumber = part_number,
  17. UpLoadId = multipart_upload['UploadId'],
  18. Body = chunk,
  19. )
  20. end_time = time.time()
  21. total_seconds = end_time - start_time
  22. print('speed is {} kb/s total seconds taken {}'.format(math.ceil((int(chunk_size) /1024) / total_seconds), total_seconds))
  23. part_output = {
  24. 'PartNumber': part_number,
  25. 'ETag': part['ETag']
  26. }
  27. return part_output
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement