in s3booster-snowball-v2.py [0:0]
def upload_file(q):
while True:
mp_data = q.get()
org_files_list = mp_data
randchar = str(gen_rand_char())
if compression == '':
tar_name = ('snowball-%s-%s.tar' % (current_time, randchar))
elif compression == 'gz':
tar_name = ('snowball-%s-%s.tgz' % (current_time, randchar))
success_log.debug('receving mp_data size: %s'% len(org_files_list))
success_log.debug('receving mp_data: %s'% org_files_list)
if mp_data == quit_flag:
break
try:
copy_to_snowball(tar_name, org_files_list)
#print('%s is uploaded' % tar_name)
except Exception as e:
error_log.info('exception error: %s uploading failed' % tar_name)
error_log.info(e)
traceback.print_exc()