Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def transfer_chunk_from_ftp_to_s3(
- ftp_file,
- s3_connection,
- muLtipart_upload,
- bucket name,
- ftp_fiLe_poth,
- s3_fiLe_path,
- part_number,
- chunksize
- ):
- start_time = time.time()
- chunk = ftp_file.read(int(chunk_size))
- part = s3_connection.upload_part(
- Bucket = bucket_name,
- Key = s3_file_path,
- PartNumber = part_number,
- UpLoadId = multipart_upload['UploadId'],
- Body = chunk,
- )
- end_time = time.time()
- total_seconds = end_time - start_time
- print('speed is {} kb/s total seconds taken {}'.format(math.ceil((int(chunk_size) /1024) / total_seconds), total_seconds))
- part_output = {
- 'PartNumber': part_number,
- 'ETag': part['ETag']
- }
- return part_output
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement