def _upload_file_to_s3(self, local_file, bucket, s3_file=None): if not s3_file: s3_file = os.path.basename(local_file) if os.path.getsize(local_file) < 1073741824: # File size is less than a gig try: self.s3.upload_file(local_file, bucket, s3_file) logger.info("\nUploaded {} to S3".format(local_file)) except FileNotFoundError: logger.error("\nThe file {} was not found".format(local_file)) except NoCredentialsError: logger.error("\nCredentials not available") else: try: self._multipart_upload(local_file, bucket, s3_file) logger.info("\nUploaded {} to S3".format(local_file)) except FileNotFoundError: logger.error("\nThe file {} was not found".format(local_file)) except NoCredentialsError: logger.error("\nCredentials not available")